diff options
Diffstat (limited to 'dmaap-dsa/src/main/java/org')
| -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) { |