X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fmessagerouter%2Fmirroragent.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fmr%2FdmaapMMAgent%2FMirrorMakerAgent.java;h=61515bc6998c5099302c6c7ccb56cc1926ddce5b;hp=de1947475d489893021b46856af299c5f954422b;hb=82136c1fd201cf815cdd85a0f02e8dd6316d6ec7;hpb=950c92fbcd3a376e7c681f1282e3aa4e4e4929d2 diff --git a/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/MirrorMakerAgent.java b/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/MirrorMakerAgent.java index de19474..61515bc 100644 --- a/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/MirrorMakerAgent.java +++ b/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/MirrorMakerAgent.java @@ -111,7 +111,7 @@ public class MirrorMakerAgent { try { input.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in checkStartup "+e); } } } @@ -128,7 +128,7 @@ public class MirrorMakerAgent { try { input.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in checkStartup "+e); } } } @@ -139,7 +139,7 @@ public class MirrorMakerAgent { return false; } logger.info("Published to Topic :" + this.topicname + " Successfully"); - response = topicUtil.subscribeTopic(topicURL, topicname, "1", response, response); + response = topicUtil.subscribeTopic(topicURL, topicname, "1", mechid, password); if (response != null && response.startsWith("ERROR:")) { logger.error("Problem subscribing to topic, please verify the config " + this.topicname + " MR URL is:" + this.topicURL + " Error is: " + response); @@ -176,7 +176,7 @@ public class MirrorMakerAgent { prop.store(out, ""); } catch (Exception e) { - e.printStackTrace(); + logger.error("exception occured in checkPropertiesFile "+e); } } finally { if (input != null) { @@ -190,7 +190,7 @@ public class MirrorMakerAgent { try { out.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in checkPropertiesFile "+e); } } }