X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fcom%2Fatt%2Fnsa%2FdmaapMMAgent%2FMirrorMakerAgent.java;h=3efbf4f533a35f2b0ab13cd1f3e5fc8c90a0f1dd;hb=refs%2Fchanges%2F57%2F30257%2F1;hp=cbe5307882745fb87ebe4fe3826cc7a1c6ee2156;hpb=2111e2b6afd982067f3d8deb170d1a257615de8a;p=dmaap%2Fmessagerouter%2Fmirroragent.git diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java index cbe5307..3efbf4f 100644 --- a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java +++ b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java @@ -95,14 +95,14 @@ public class MirrorMakerAgent { input = new FileInputStream(mmagenthome + "/etc/mmagent.config"); logger.info("mmagenthome is set :" + mmagenthome + " loading properties at /etc/mmagent.config"); } catch (IOException ex) { - logger.error(mmagenthome + "/etc/mmagent.config not found. Set -DMMAGENTHOME and check the config file"); + logger.error(mmagenthome + "/etc/mmagent.config not found. Set -DMMAGENTHOME and check the config file" + ex); return false; } finally { if (input != null) { 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();