From a4e26fe5631174da6718dec2ee97be5e34e9f73e Mon Sep 17 00:00:00 2001 From: Guangrong Fu Date: Wed, 8 Nov 2017 14:11:43 +0800 Subject: [PATCH] Add Some Log Printing Change-Id: I4d9cbbd02e272bd70e9d31a94ca07de055101123 Issue-ID: HOLMES-86 Signed-off-by: Guangrong Fu --- .../src/main/java/org/onap/holmes/engine/dmaap/DMaaPAlarmPolling.java | 4 +++- .../src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java | 4 ++++ 2 files changed, 7 insertions(+), 1 deletion(-) 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 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)); } } diff --git a/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java b/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java index 8d80a6b..12edc99 100644 --- a/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java +++ b/engine-d/src/main/java/org/onap/holmes/engine/dmaap/SubscriberAction.java @@ -21,11 +21,13 @@ import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import javax.annotation.PreDestroy; import javax.inject.Inject; +import lombok.extern.slf4j.Slf4j; import org.jvnet.hk2.annotations.Service; import org.onap.holmes.dsa.dmaappolling.Subscriber; import org.onap.holmes.engine.manager.DroolsEngine; @Service +@Slf4j public class SubscriberAction { @Inject @@ -38,6 +40,7 @@ public class SubscriberAction { Thread thread = new Thread(pollingTask); thread.start(); pollingTasks.put(subscriber.getTopic(), pollingTask); + log.info("Subscribe to topic: " + subscriber.getUrl()); } } @@ -46,6 +49,7 @@ public class SubscriberAction { pollingTasks.get(subscriber.getTopic()).stopTask(); pollingTasks.remove(subscriber.getTopic()); } + log.info("Topic unsubscribed: " + subscriber.getUrl()); } @PreDestroy -- 2.16.6