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%2Futils%2FMirrorMakerProcessHandler.java;h=883d1514d1f9bc478731c098fdcb77a1464bca8f;hp=114d1f86539e16294c559e89099010398f99eb83;hb=67f4f5aead42107dd941772ebb4c3cd4a89424a3;hpb=2fb7a686abae1fcdd8ae06c8abeb759c2bcfd069

diff --git a/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java b/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
index 114d1f8..883d151 100644
--- a/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
+++ b/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
@@ -29,7 +29,7 @@ import org.apache.log4j.Logger;
 
 public class MirrorMakerProcessHandler {
 	static final Logger logger = Logger.getLogger(MirrorMakerProcessHandler.class);
-	static String mmagenthome = System.getProperty("MMAGENTHOME");
+	static String mmagenthome = "/opt";
 
 	public static boolean checkMirrorMakerProcess(String agentname, boolean enablelogCheck, String grepLog) throws Exception {
 		String line,linelog;
@@ -135,7 +135,7 @@ public class MirrorMakerProcessHandler {
 
 			logger.info("Mirror Maker " + agentname + " Stopped");
 		} catch (Exception e) {
-			e.printStackTrace();
+		    logger.error("exception occured in stopMirrorMaker ", e);
 		}
 
 	}
@@ -163,7 +163,7 @@ public class MirrorMakerProcessHandler {
 								// System.out.println(line);
 							}
 						} catch (Exception anExc) {
-							anExc.printStackTrace();
+						    logger.error("exception occured in startMirrorMaker ", anExc);
 						}
 					}
 				}.start();
@@ -171,8 +171,8 @@ public class MirrorMakerProcessHandler {
 				String args[] = { "/bin/sh", "-c",
 						kafkaHome + "/bin/kafka-run-class.sh -Dagentname=" + agentName
 						+ " kafka.tools.MirrorMaker --consumer.config " + consumerConfig
-						+ " --producer.config " + producerConfig + " --num.streams " + numStreams + "  --abort.on.send.failure true" + " --whitelist '" + whitelist + "' 2>&1 >"
-						+ mmagenthome + "/logs/" + agentName + "_MMaker.log " };
+						+ " --producer.config " + producerConfig + " --num.streams " + numStreams + "  --abort.on.send.failure true" + " --whitelist '" + whitelist + "'  >"
+						+ mmagenthome + "/logs/" + agentName + "_MMaker.log 2>&1" };
 				final Process process = rt.exec(args);
 				new Thread() {
 					public void run() {
@@ -185,7 +185,7 @@ public class MirrorMakerProcessHandler {
 								// System.out.println(line);
 							}
 						} catch (Exception anExc) {
-							anExc.printStackTrace();
+						    logger.error("exception occured in startMirrorMaker ", anExc);
 						}
 					}
 				}.start();
@@ -194,7 +194,7 @@ public class MirrorMakerProcessHandler {
 			logger.info("Mirror Maker " + agentName + " Started" + " WhiteListing:" + whitelist);
 
 		} catch (Exception e) {
-			e.printStackTrace();
+		    logger.error("exception occured in startMirrorMaker ", e);
 		}
 	}
 }