diff options
author | tang peng <tang.peng5@zte.com.cn> | 2017-11-08 06:17:46 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@onap.org> | 2017-11-08 06:17:46 +0000 |
commit | 02913e9423547ceaeb05b94972c6908e16f2e1a5 (patch) | |
tree | f35f9d80a095910cfde9bc16a0390a665436289d /engine-d/src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java | |
parent | af1347f3aeb77096ef6a588ac4e6ed01300d64bc (diff) | |
parent | a4e26fe5631174da6718dec2ee97be5e34e9f73e (diff) |
Merge "Add Some Log Printing"
Diffstat (limited to 'engine-d/src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java')
-rw-r--r-- | engine-d/src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/engine-d/src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java b/engine-d/src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java index 37b39c0..47bd386 100644 --- a/engine-d/src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java +++ b/engine-d/src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java @@ -40,10 +40,12 @@ public class DMaaPAlarmPolling implements Runnable { List<VesAlarm> vesAlarmList = new ArrayList<>(); try { vesAlarmList = subscriber.subscribe(); + vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm)); } catch (CorrelationException e) { log.error("Failed polling request alarm. " + e.getMessage()); + } catch (Exception e) { + log.error("An error occurred while processing alarm.", e); } - vesAlarmList.forEach(vesAlarm -> droolsEngine.putRaisedIntoStream(vesAlarm)); } } |