diff options
| author |   Shiwei Tian <tian.shiwei@zte.com.cn> | 2017-10-16 10:37:55 +0800 |
|---|---|---|
| committer | Shiwei Tian <tian.shiwei@zte.com.cn> | 2017-10-16 10:37:55 +0800 |
| commit | bca100aebd44842fc640f2005d6da22c7ee4a4ff (patch) | |
| tree | c19ef3bd3888fa5e8855208d4b3cd2e06378b0d7 | |
| parent | 16108263545743a3a732e8f1e5ae207fc5576a62 (diff) | |
modify bug
Issue-ID: HOLMES-71
Change-Id: I96553e6c47ee77f2b3559d8413edd724afa1865b
Signed-off-by: Shiwei Tian <tian.shiwei@zte.com.cn>
| -rw-r--r-- | dmaap-dsa/src/main/java/org/onap/holmes/dsa/dmaappolling/Subscriber.java | 11 |
1 files changed, 8 insertions, 3 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 eea1533..55b7558 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 @@ -57,13 +57,18 @@ public class Subscriber { private boolean secure; private String topic; private String url; - private String consumerGroup = "g0"; - private String consumer = "u1"; + private String consumerGroup = "homlesGrounp1"; + private String consumer = "homlesGrounp1"; private String authInfo; private String authExpDate; public List<VesAlarm> subscribe() throws CorrelationException { - List<String> response = getDMaaPData(); + List<String> response; + try { + response = getDMaaPData(); + } catch (Exception e) { + throw new CorrelationException("Failed to connect to DMapp.", e); + } try { return extractVesAlarm(response); } catch (Exception e) { |