import org.apache.log4j.Logger;
-public class MirrorMakerProcessHandler {/*
+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;
} else {
//String args[] = { "/bin/sh", "-c", "ps -ef |grep java |grep agentname=" + agentname + "~" };
- String args[] = { "/bin/sh", "-c", "ps -ef | grep `ps -ef |grep agentname=" + agentname + "~ | egrep -v 'grep|java' | awk '{print $2}' `| egrep -v '/bin/sh|grep' "};
+ String args[] = { "/bin/sh", "-c", "ps -ef |grep agentname=" + agentname + "| grep -v grep | awk '{print $1}'"};
logger.info("CheckMM process->"+args[2]);
mmprocess = rt.exec(args);
}
BufferedReader br = new BufferedReader(isr);
while ((line = br.readLine()) != null) {
- System.out.println(line);
+ logger.info(line);
// if (line.contains("agentname=" + agentname) && line.contains("/bin/sh -c") == false) {
//If enablelogCheck Check MirrorMaker log for errors and restart mirrormaker
// }
}
} catch (Exception e) {
- e.printStackTrace();
+ logger.error("Error occured in MirrorMakerProcessHandler.checkMirrorMakerProcess"+e);
}
return false;
}
//String args[] = { "/bin/sh", "-c",
// "kill -9 `ps -ef |grep agentname=" + agentname + "~| egrep -v 'grep|java' | awk '{print $2}'` | egrep -v '/bin/sh|grep'"};
String args[] = { "/bin/sh", "-c",
- "for i in `ps -ef |grep agentname="+ agentname + "~ | egrep -v 'grep|java' | awk '{print $2}'`;do kill -9 `ps -eaf | grep $i | egrep -v '/bin/sh|grep' | awk '{print $2}'` ;done"};
+ "kill -9 $(ps -ef | grep agentname=" + agentname + "| grep -v grep | awk '{print $1}')"};
logger.info ("Stop MM ->"+args[2]);
// args = "kill $(ps -ef |grep java |grep agentname=" +
// agentname + "~| awk '{print $2}')";
logger.info("Mirror Maker " + agentname + " Stopped");
} catch (Exception e) {
- e.printStackTrace();
+ logger.error("exception occured in stopMirrorMaker ", e);
}
}
// System.out.println(line);
}
} catch (Exception anExc) {
- anExc.printStackTrace();
+ logger.error("exception occured in startMirrorMaker ", anExc);
}
}
}.start();
} else {
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 + "' >"
- + mmagenthome + "/logs/" + agentName + "_MMaker.log 2>&1" };
+ + " kafka.tools.MirrorMaker --consumer.config " + consumerConfig
+ + " --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() {
// System.out.println(line);
}
} catch (Exception anExc) {
- anExc.printStackTrace();
+ logger.error("exception occured in startMirrorMaker ", anExc);
}
}
}.start();
logger.info("Mirror Maker " + agentName + " Started" + " WhiteListing:" + whitelist);
} catch (Exception e) {
- e.printStackTrace();
+ logger.error("exception occured in startMirrorMaker ", e);
}
}
-*/}
+}