No topic dups in mmagent whitelist

[dmaap/dbcapi.git] / src / main / java / org / onap / dmaap / dbcapi / model / MirrorMaker.java

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 b1a2d3c..9f6f402 100644 (file)
--- a/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java
+++ b/src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java
@@ -137,11 +137,11 @@ public class MirrorMaker extends DmaapObject {
                                }
                        }
         */
-       public String createMirrorMaker() {
+       public String createMirrorMaker( String consumerPort, String producerPort ) {
                StringBuilder str = new StringBuilder( "{ \"messageID\": \"" + MirrorMakerService.genTransactionId() + "\", \"createMirrorMaker\": {"  );
                str.append( " \"name\": \"" + this.getMmName() + "\", " );
-               str.append( " \"consumer\": \"" + this.sourceCluster + ":2181\", " );
-               str.append( " \"producer\": \"" + this.targetCluster + ":9092\" ");
+               str.append( " \"consumer\": \"" + this.sourceCluster + ":" + consumerPort + "\", " );
+               str.append( " \"producer\": \"" + this.targetCluster + ":" + producerPort + "\" ");
                
                str.append( " } }" );
                
@@ -194,7 +194,10 @@ public class MirrorMaker extends DmaapObject {
 
        
        public void addTopic( String topic ) {
-               topics.add(topic);
+               if ( ! topics.contains(topic)) {        
+                       topics.add(topic);
+               }
+               logger.info( "Mirrormaker.addTopic: topic=" + topic + " . Now have " + topics.size() + " topics" );
        }
        
        public int getTopicCount() {