diff options
Diffstat (limited to 'src/main/java/org/onap')
| -rw-r--r-- | src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java | 12 |
1 files changed, 3 insertions, 9 deletions
diff --git a/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java b/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java index e693afe..ab183d6 100644 --- a/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java +++ b/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java @@ -20,14 +20,10 @@ package org.onap.dmaap.dbcapi.model; -import java.util.ArrayList; -import java.util.HashSet; -import java.util.Set; - -import org.apache.log4j.Logger; -import org.onap.dmaap.dbcapi.logging.DmaapbcLogMessageEnum; import org.onap.dmaap.dbcapi.service.MirrorMakerService; +import java.util.ArrayList; + public class MirrorMaker extends DmaapObject { @@ -58,7 +54,7 @@ public class MirrorMaker extends DmaapObject { sourceCluster = source; targetCluster = target; mmName = genKey(source, target); - topics = new ArrayList<String>(); + topics = new ArrayList<>(); } @@ -89,12 +85,10 @@ public class MirrorMaker extends DmaapObject { str.append( " \"name\": \"" + this.getMmName() + "\", \"whitelist\": \"" ); int numTargets = 0; - //for (ReplicationVector rv: vectors) { for (String rv: topics) { if ( numTargets > 0 ) { str.append( ","); } - //str.append( rv.getFqtn() ); str.append( rv ); numTargets++; } |