X-Git-Url: https://gerrit.onap.org/r/gitweb?p=dmaap%2Fdbcapi.git;a=blobdiff_plain;f=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fmodel%2FMirrorMaker.java;fp=src%2Fmain%2Fjava%2Forg%2Fonap%2Fdmaap%2Fdbcapi%2Fmodel%2FMirrorMaker.java;h=1e381b8444bdea1363c2a5b4a93a61b540eccea6;hp=b1a2d3c267bf383c3a7221e57cff42505f605812;hb=ad29261e05ff057134d48b7d6a99da1cd07849e0;hpb=9308e9cbaa6c20a0b171b6524a834ef36feaa9f0

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..1e381b8 100644
--- 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( " } }" );