summaryrefslogtreecommitdiffstats
path: root/src/main
diff options
context:
space:
mode:
Diffstat (limited to 'src/main')
-rw-r--r--src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java16
1 files changed, 11 insertions, 5 deletions
diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java
index b28fb07..e533a72 100644
--- a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java
+++ b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java
@@ -36,6 +36,7 @@ import java.net.URL;
import java.util.ArrayList;
import java.util.Properties;
+import org.apache.log4j.Level;
import org.apache.log4j.Logger;
import org.jasypt.util.text.BasicTextEncryptor;
@@ -174,7 +175,7 @@ public class MirrorMakerAgent {
try {
input.close();
} catch (IOException e) {
- e.printStackTrace();
+ logger.error("Exception occurred is " +e);
}
}
if (out != null) {
@@ -212,6 +213,7 @@ public class MirrorMakerAgent {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
+ Thread.currentThread().interrupt();
}
mirrorMakers.getListMirrorMaker().set(i, mm);
} else {
@@ -252,6 +254,7 @@ public class MirrorMakerAgent {
return topicMessage[0];
}
} catch (Exception e) {
+ logger.error(" Exception Occered " + e);
return "ERROR:" + e.getMessage() + " Server Response is:" + response;
}
return null;
@@ -282,6 +285,7 @@ public class MirrorMakerAgent {
return response;
} catch (Exception e) {
+ logger.error(" Exception Occered " + e);
return "ERROR:" + e.getLocalizedMessage();
}
}
@@ -347,7 +351,7 @@ public class MirrorMakerAgent {
} catch (Exception ex) {
connectionattempt++;
if (connectionattempt > 5) {
- logger.info("Can't connect to the topic, mmagent shutting down , " + topicMessage);
+ logger.info("Can't connect to the topic, mmagent shutting down , " + topicMessage + ex);
return;
}
logger.info("Can't connect to the topic, " + topicMessage + " Retrying " + connectionattempt
@@ -362,7 +366,7 @@ public class MirrorMakerAgent {
}
} catch (Exception e) {
- e.printStackTrace();
+ logger.error("Exception is : " +e);
}
}
@@ -441,15 +445,17 @@ public class MirrorMakerAgent {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
+ logger.log(Level.WARN, "Interrupted!", e);
+ Thread.currentThread().interrupt();
}
} catch (IOException ex) {
- ex.printStackTrace();
+ logger.error(" IOException Occered " + ex);
} finally {
if (out != null) {
try {
out.close();
} catch (IOException e) {
- e.printStackTrace();
+ logger.error(" IOException Occered " + e);
}
}
}