static final Logger logger = Logger.getLogger(MirrorMakerAgent.class);
Properties mirrorMakerProperties = new Properties();
ListMirrorMaker mirrorMakers = null;
- String mmagenthome = "";
+ String mmagenthome = "/opt";
String kafkahome = "";
String topicURL = "";
String topicname = "";
private boolean checkStartup() {
FileInputStream input = null;
try {
- this.mmagenthome = System.getProperty("MMAGENTHOME");
+ //this.mmagenthome = System.getProperty("MMAGENTHOME");
input = new FileInputStream(mmagenthome + "/etc/mmagent.config");
logger.info("mmagenthome is set :" + mmagenthome + " loading properties at /etc/mmagent.config");
} catch (IOException ex) {
try {
input.close();
} catch (IOException e) {
- e.printStackTrace();
+ logger.error("exception occured in checkStartup "+e);
}
}
}
try {
input.close();
} catch (IOException e) {
- e.printStackTrace();
+ logger.error("exception occured in checkStartup "+e);
}
}
}
prop.store(out, "");
} catch (Exception e) {
- e.printStackTrace();
+ logger.error("exception occured in checkPropertiesFile "+e);
}
} finally {
if (input != null) {
try {
out.close();
} catch (IOException e) {
- e.printStackTrace();
+ logger.error("exception occured in checkPropertiesFile "+e);
}
}
}
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;
}