diff options
| author |   Varun Gudisena <vg411h@att.com> | 2017-10-02 22:28:13 +0000 |
|---|---|---|
| committer | Varun Gudisena <vg411h@att.com> | 2017-10-02 22:31:23 +0000 |
| commit | 2111e2b6afd982067f3d8deb170d1a257615de8a (patch) | |
| tree | 906ce8d8b1d382c789c2c1d91a38ab1d0347c9b9 /src | |
| parent | 17279873f34362be48a64af5841555833d6cf32b (diff) | |
Add unit test cases
Add unit test cases
Issue-Id: DMAAP-149
Change-Id: I754c3bf6513f5526597105211d7a8a098abcea25
Signed-off-by: Varun Gudisena <vg411h@att.com>
Diffstat (limited to 'src')
| -rw-r--r-- | src/main/java/com/att/nsa/dmaapMMAgent/MirrorMakerAgent.java | 7 | ||||
| -rw-r--r-- | src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java | 1 |
2 files changed, 6 insertions, 2 deletions
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); |