summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorFei Tang <tang.fei4@zte.com.cn>2018-03-27 17:10:50 +0800
committerFei Tang <tang.fei4@zte.com.cn>2018-03-27 17:10:50 +0800
commit199919ee4f65cb71ba33fec2bbb996589c696d01 (patch)
tree11fd1e16a40d8efd9a8731c3c69574f9ddff4837
parente8ff4250ec0ef6936b9e3990474548cf18d859de (diff)
add alarm synchronization related operation
Issue-ID: HOLMES-106 Change-Id: Ifa9d77b18669ccf9cd7b1d52994c2b9ce5c2cc57 Signed-off-by: Fei Tang <tang.fei4@zte.com.cn>
-rw-r--r--dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java7
1 files changed, 5 insertions, 2 deletions
diff --git a/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java b/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java
index 4d0b058..e4276d4 100644
--- a/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java
+++ b/dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java
@@ -20,6 +20,8 @@ import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
+import java.util.UUID;
+
import lombok.Getter;
import lombok.Setter;
import org.apache.http.HttpResponse;
@@ -56,8 +58,9 @@ public class Subscriber {
private boolean secure;
private String topic;
private String url;
- private String consumerGroup = "homlesGroup1";
- private String consumer = "homles1";
+ private String uuid = UUID.randomUUID() + "";
+ private String consumerGroup = "homlesGroup" + uuid;
+ private String consumer = "homles" + uuid;
private String authInfo;
private String authExpDate;