X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fmessagerouter%2Fmirroragent.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fcom%2Fatt%2Fnsa%2FdmaapMMAgent%2FMirrorMakerAgent.java;h=3efbf4f533a35f2b0ab13cd1f3e5fc8c90a0f1dd;hp=9c74f727027f93715edd6d4fb637f28868f903f4;hb=c4999261363c42758b50b31d33f910c5344fb339;hpb=b0e8b887027d6b67c91cce046e7c0a769b0728b0 diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java index 9c74f72..3efbf4f 100644 --- a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java +++ b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java @@ -102,7 +102,7 @@ public class MirrorMakerAgent { try { input.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("IOException" + e); } } } @@ -115,14 +115,14 @@ public class MirrorMakerAgent { } logger.info("kakahome is set :" + kafkahome); } catch (IOException ex) { - logger.error(kafkahome + "/bin/kafka-run-class.sh not found. Make sure kafka home is set correctly"); + logger.error(kafkahome + "/bin/kafka-run-class.sh not found. Make sure kafka home is set correctly" + ex); return false; } finally { if (input != null) { try { input.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("IOException" + e); } } } @@ -181,6 +181,7 @@ public class MirrorMakerAgent { out.close(); } catch (IOException e) { e.printStackTrace(); + logger.error("IOException" + e); } } } @@ -379,7 +380,7 @@ public class MirrorMakerAgent { } } logger.info("Adding new MirrorMaker:" + newMirrorMaker.name); - if (exists == false && mirrorMakers != null) { + if (!exists && mirrorMakers != null) { mirrorMakers.getListMirrorMaker().add(newMirrorMaker); } else if (exists == false && mirrorMakers == null) { mirrorMakers = new ListMirrorMaker();