diff options
author | Fei Tang <tang.fei4@zte.com.cn> | 2018-03-27 17:10:50 +0800 |
---|---|---|
committer | Fei Tang <tang.fei4@zte.com.cn> | 2018-03-27 17:10:50 +0800 |
commit | 199919ee4f65cb71ba33fec2bbb996589c696d01 (patch) | |
tree | 11fd1e16a40d8efd9a8731c3c69574f9ddff4837 /dmaap-dsa/src | |
parent | e8ff4250ec0ef6936b9e3990474548cf18d859de (diff) |
add alarm synchronization related operation
Issue-ID: HOLMES-106
Change-Id: Ifa9d77b18669ccf9cd7b1d52994c2b9ce5c2cc57
Signed-off-by: Fei Tang <tang.fei4@zte.com.cn>
Diffstat (limited to 'dmaap-dsa/src')
-rw-r--r-- | dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java | 7 |
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; |