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=9af38092d2a8bcdf09bb17c66effca22ab61422f;hp=23fd99f842a192dd323fefad4749634abbe41378;hb=67f4f5aead42107dd941772ebb4c3cd4a89424a3;hpb=36c24531b60b2a0b909c2594f6f37741b1901ca7 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 23fd99f..9af3809 100644 --- a/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/MirrorMakerAgent.java +++ b/src/main/java/org/onap/dmaap/mr/dmaapMMAgent/MirrorMakerAgent.java @@ -21,23 +21,18 @@ *******************************************************************************/ package org.onap.dmaap.mr.dmaapMMAgent; -import java.io.BufferedReader; -import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; import java.io.InputStream; -import java.io.InputStreamReader; import java.io.OutputStream; -import java.net.HttpURLConnection; -import java.net.URL; import java.util.ArrayList; import java.util.Properties; -import org.json.JSONObject; + import org.apache.log4j.Logger; import org.jasypt.util.text.BasicTextEncryptor; - +import org.json.JSONObject; import org.onap.dmaap.mr.dmaapMMAgent.dao.CreateMirrorMaker; import org.onap.dmaap.mr.dmaapMMAgent.dao.DeleteMirrorMaker; import org.onap.dmaap.mr.dmaapMMAgent.dao.ListMirrorMaker; @@ -45,18 +40,15 @@ import org.onap.dmaap.mr.dmaapMMAgent.dao.MirrorMaker; import org.onap.dmaap.mr.dmaapMMAgent.dao.UpdateMirrorMaker; import org.onap.dmaap.mr.dmaapMMAgent.dao.UpdateWhiteList; import org.onap.dmaap.mr.dmaapMMAgent.utils.MirrorMakerProcessHandler; + import com.google.gson.Gson; -import com.google.gson.JsonArray; import com.google.gson.internal.LinkedTreeMap; -import com.sun.org.apache.xerces.internal.impl.dtd.models.CMAny; -import com.sun.org.apache.xerces.internal.impl.dv.util.Base64; - public class MirrorMakerAgent { 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 = ""; @@ -87,8 +79,7 @@ public class MirrorMakerAgent { try { agent.checkAgentProcess(); } catch (Exception e) { - - e.printStackTrace(); + logger.error("exception occured in checkAgentProcess ", e); } agent.readAgentTopic(); } else { @@ -100,11 +91,10 @@ public class MirrorMakerAgent { private boolean checkStartup() { FileInputStream input = null; try { - 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) { - logger.error(mmagenthome + "/etc/mmagent.config not found. Set -DMMAGENTHOME and check the config file"); + logger.error(mmagenthome + "/etc/mmagent.config not found.", ex); return false; } finally { if (input != null) { @@ -119,9 +109,9 @@ public class MirrorMakerAgent { input = null; try { input = new FileInputStream(kafkahome + "/bin/kafka-run-class.sh"); - logger.info("kakahome is set :" + kafkahome); + logger.info("kafkahome 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) { @@ -139,7 +129,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); @@ -183,7 +173,7 @@ public class MirrorMakerAgent { try { input.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in checkPropertiesFile ", e); } } if (out != null) { @@ -278,7 +268,7 @@ public class MirrorMakerAgent { } } catch (Exception e) { - e.printStackTrace(); + logger.error("exception occured in readAgentTopic ", e); } } @@ -316,13 +306,13 @@ public class MirrorMakerAgent { out = new FileOutputStream(mmagenthome + "/etc/mmagent.config"); mirrorMakerProperties.store(out, ""); } catch (IOException ex) { - ex.printStackTrace(); + logger.error("exception occured in createMirrorMaker ", ex); } finally { if (out != null) { try { out.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in createMirrorMaker ", e); } } } @@ -370,13 +360,13 @@ public class MirrorMakerAgent { } catch (InterruptedException e) { } } catch (IOException ex) { - ex.printStackTrace(); + logger.error("exception occured in updateMirrorMaker ", ex); } finally { if (out != null) { try { out.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in updateMirrorMaker ", e); } } } @@ -413,13 +403,13 @@ public class MirrorMakerAgent { } catch (InterruptedException e) { } } catch (IOException ex) { - ex.printStackTrace(); + logger.error("exception occured in updateWhiteList ", ex); } finally { if (out != null) { try { out.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in updateWhiteList ", e); } } } @@ -448,12 +438,14 @@ public class MirrorMakerAgent { File file = new File(path); file.delete(); } catch (Exception ex) { + logger.error("exception occured in deleteMirrorMaker ", ex); } try { String path = mmagenthome + "/etc/" + newMirrorMaker.name + "producer" + ".properties"; File file = new File(path); file.delete(); } catch (Exception ex) { + logger.error("exception occured in deleteMirrorMaker ", ex); } Gson g = new Gson(); mirrorMakerProperties.setProperty("mirrormakers", g.toJson(this.mirrorMakers)); @@ -463,13 +455,13 @@ public class MirrorMakerAgent { mirrorMakerProperties.store(out, ""); MirrorMakerProcessHandler.stopMirrorMaker(newMirrorMaker.name); } catch (IOException ex) { - ex.printStackTrace(); + logger.error("exception occured in deleteMirrorMaker ", ex); } finally { if (out != null) { try { out.close(); } catch (IOException e) { - e.printStackTrace(); + logger.error("exception occured in deleteMirrorMaker ", e); } } } @@ -488,7 +480,7 @@ public class MirrorMakerAgent { if (mirrorMakerProperties.getProperty("mirrormakers") == null) { this.mirrorMakers = new ListMirrorMaker(); ArrayList list = this.mirrorMakers.getListMirrorMaker(); - list = new ArrayList(); + list = new ArrayList<>(); this.mirrorMakers.setListMirrorMaker(list); } else { this.mirrorMakers = g.fromJson(mirrorMakerProperties.getProperty("mirrormakers"), @@ -505,13 +497,13 @@ public class MirrorMakerAgent { textEncryptor.setPassword(secret); this.password = textEncryptor.decrypt(mirrorMakerProperties.getProperty("password")); } catch (Exception ex) { - // ex.printStackTrace(); + logger.error("exception occured in loadProperties ", ex); } finally { if (input != null) { try { input.close(); } catch (IOException e) { - // e.printStackTrace(); + logger.error("exception occured in loadProperties ", e); } } }