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 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java') 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(); -- cgit 1.2.3-korg