Merge "reverted the testcases"

diff --git a/pom.xml b/pom.xml
index 270767e..2410b9c 100644 (file)
--- a/pom.xml
+++ b/pom.xml
@@ -31,7 +31,7 @@
        <parent>
                <groupId>org.onap.oparent</groupId>
                <artifactId>oparent</artifactId>
-               <version>0.1.1</version>
+               <version>1.1.0</version>
        </parent>
 
        <name>dmaap-messagerouter-mirroragent</name>

diff --git a/src/main/java/com/att/nsa/dmaapMMAgent/dao/CreateMirrorMaker.java b/src/main/java/com/att/nsa/dmaapMMAgent/dao/CreateMirrorMaker.java
index 7094ba4..1c1e978 100644 (file)
--- a/src/main/java/com/att/nsa/dmaapMMAgent/dao/CreateMirrorMaker.java
+++ b/src/main/java/com/att/nsa/dmaapMMAgent/dao/CreateMirrorMaker.java
@@ -24,14 +24,14 @@ package com.att.nsa.dmaapMMAgent.dao;
 
 public class CreateMirrorMaker {
        String messageID;
-       MirrorMaker createMirrorMaker;
+       MirrorMaker MirrorMaker;
 
        public MirrorMaker getCreateMirrorMaker() {
-               return createMirrorMaker;
+               return MirrorMaker;
        }
 
        public void setCreateMirrorMaker(MirrorMaker createMirrorMaker) {
-               this.createMirrorMaker = createMirrorMaker;
+               this.MirrorMaker = createMirrorMaker;
        }
 
        public String getMessageID() {

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 dd1442e..fde1145 100644 (file)
--- a/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
+++ b/src/main/java/com/att/nsa/dmaapMMAgent/utils/MirrorMakerProcessHandler.java
@@ -109,6 +109,7 @@ public class MirrorMakerProcessHandler {
                                                + "_MMaker.log";
                                final Process process = rt.exec(args);
                                new Thread() {
+                                       @Override
                                        public void run() {
                                                try {
                                                        InputStream is = process.getInputStream();