aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java3
-rw-r--r--src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyNotificationCallback.java7
-rw-r--r--src/main/java/org/onap/dcaegen2/services/sonhms/model/PolicyNotification.java2
3 files changed, 6 insertions, 6 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java b/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java
index b9ab254..5b7a58f 100644
--- a/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java
+++ b/src/main/java/org/onap/dcaegen2/services/sonhms/PmNotificationHandler.java
@@ -223,9 +223,6 @@ public class PmNotificationHandler {
log.info("Policy Notification: {}", notification);
Boolean result = policyDmaapClient.sendNotificationToPolicy(notification);
log.info("send notification to policy result {} ", result);
- // getting policy response
- policyDmaapClient.handlePolicyResponse(requestId);
- log.info("handled policy response");
} catch (Exception e) {
log.error("Exception in sending Anr update to policy ", e);
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyNotificationCallback.java b/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyNotificationCallback.java
index 82e940d..ad2baf5 100644
--- a/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyNotificationCallback.java
+++ b/src/main/java/org/onap/dcaegen2/services/sonhms/dmaap/PolicyNotificationCallback.java
@@ -45,8 +45,9 @@ public class PolicyNotificationCallback extends NotificationCallback {
}
private void handlePolicyNotification(String msg) {
+ log.info("Message received from policy: " +msg);
PciUpdateRepository pciUpdateRepository = BeanUtil.getBean(PciUpdateRepository.class);
- Configuration configuration = Configuration.getInstance();
+ Configuration configuration = Configuration.getInstance();
try {
ObjectMapper mapper = new ObjectMapper();
PolicyNotification policyResponse = mapper.readValue(msg, PolicyNotification.class);
@@ -82,8 +83,8 @@ public class PolicyNotificationCallback extends NotificationCallback {
String statusToString = Integer.toString(status);
log.info("Handled response from policy, status code {}", statusToString);
}
- } catch (IOException e) {
- log.info("caught io exception while fetching policy response");
+ } catch (Exception e) {
+ log.info("caught exception while fetching policy response:" + e);
}
}
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/model/PolicyNotification.java b/src/main/java/org/onap/dcaegen2/services/sonhms/model/PolicyNotification.java
index 2cb1335..8766dff 100644
--- a/src/main/java/org/onap/dcaegen2/services/sonhms/model/PolicyNotification.java
+++ b/src/main/java/org/onap/dcaegen2/services/sonhms/model/PolicyNotification.java
@@ -80,6 +80,8 @@ public class PolicyNotification {
aai.put("generic-vnf.is-closed-loop-disabled", "false");
aai.put("generic-vnf.prov-status", "ACTIVE");
aai.put("pnf.pnf-name", pnfName);
+ this.policyName = "PCI";
+ this.policyVersion = "1.0.2";
}
public long getClosedLoopAlarmStart() {