diff options
Diffstat (limited to 'src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java')
| -rw-r--r-- | src/main/java/org/onap/dmaap/dbcapi/model/MirrorMaker.java | 6 |
1 files changed, 3 insertions, 3 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 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( " } }" ); |