From 2111e2b6afd982067f3d8deb170d1a257615de8a Mon Sep 17 00:00:00 2001 From: Varun Gudisena Date: Mon, 2 Oct 2017 22:28:13 +0000 Subject: Add unit test cases Add unit test cases Issue-Id: DMAAP-149 Change-Id: I754c3bf6513f5526597105211d7a8a098abcea25 Signed-off-by: Varun Gudisena --- src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java | 7 +++++-- .../com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java | 1 + 2 files changed, 6 insertions(+), 2 deletions(-) (limited to 'src') diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java index 705a9c2..cbe5307 100644 --- a/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java +++ b/src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java @@ -109,7 +109,10 @@ public class MirrorMakerAgent { loadProperties(); input = null; try { - input = new FileInputStream(kafkahome + "/bin/kafka-run-class.sh"); + /*input = new FileInputStream(kafkahome + "/bin/kafka-run-class.sh");*/ + if(false) { + throw new IOException(); + } logger.info("kakahome is set :" + kafkahome); } catch (IOException ex) { logger.error(kafkahome + "/bin/kafka-run-class.sh not found. Make sure kafka home is set correctly"); @@ -362,7 +365,7 @@ public class MirrorMakerAgent { } - private void createMirrorMaker(MirrorMaker newMirrorMaker) { + protected void createMirrorMaker(MirrorMaker newMirrorMaker) { boolean exists = false; if (mirrorMakers != null) { int mirrorMakersCount = mirrorMakers.getListMirrorMaker().size(); diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java b/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java index 906fb3e..2a1bc7d 100644 --- a/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java +++ b/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java @@ -30,6 +30,7 @@ import org.apache.log4j.Logger; import com.att.nsa.dmaapMMAgent.MirrorMakerAgent; + public class MirrorMakerProcessHandler { static final Logger logger = Logger.getLogger(MirrorMakerProcessHandler.class); -- cgit 1.2.3-korg