summaryrefslogtreecommitdiffstats
path: root/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java
diff options
context:
space:
mode:
authordhebeha <dhebeha.mj71@wipro.com>2020-09-08 13:02:32 +0530
committerdhebeha <dhebeha.mj71@wipro.com>2020-09-15 22:11:14 +0530
commit8882e23eedce9e9236e1d979b2056b62dd974d91 (patch)
treeff7bce29e94a814c340df73607b9d0da59a1329a /components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java
parent2c6ad52e8d0e29b8037776fff035f031558cc4b0 (diff)
Add support to consume, process pm message from DB
- Add support for analysing pm data - Add support to trigger closed loop - Add support for configDb Interface Implementation - Add support for Intelligent slicing Issue-ID: DCAEGEN2-2255 Signed-off-by: dhebeha <dhebeha.mj71@wipro.com> Change-Id: I185dbb6da45ae6ee74f0a090e2d604914163588b
Diffstat (limited to 'components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java')
-rw-r--r--components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java
index 57aadd18..146b60a9 100644
--- a/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java
+++ b/components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java
@@ -26,7 +26,7 @@ import org.slf4j.Logger;
/**
* Handles Notification on dmaap for Policy events
*/
-public class PolicyNotificationCallback extends NotificationCallback {
+public class PolicyNotificationCallback implements NotificationCallback {
private static final Logger log = org.slf4j.LoggerFactory.getLogger(PolicyNotificationCallback.class);
@@ -43,7 +43,7 @@ public class PolicyNotificationCallback extends NotificationCallback {
* @param msg
*/
private void handlePolicyNotification(String msg) {
- log.info("Message received from policy: " +msg);
- //TBD - actions to perform on reception of notification from policy
+ log.info("Message received from policy: " +msg);
+ //TBD - actions to perform on reception of notification from policy
}
}