diff options
| author |   Niranjana <niranjana.y60@wipro.com> | 2020-06-17 20:37:05 +0530 |
|---|---|---|
| committer | Niranjana Y <niranjana.y60@wipro.com> | 2020-07-09 13:22:01 +0000 |
| commit | e1d4f91bc19da52068f924d20650a8c4bff5d0c9 (patch) | |
| tree | c84ff5a10adb992a90f46dc6ca59191a7907bb16 /src/main/java | |
| parent | 2d055a7021253f44100ed8352ade75e8099c0c7e (diff) | |
Modify policy-notification to align with policy.6.0.1-ONAPfrankfurt
Issue-ID: DCAEGEN2-2216
Signed-off-by: Niranjana <niranjana.y60@wipro.com>
Change-Id: I768b4cf785dacc865b0312f5c2ccfdccf2e32a14
Diffstat (limited to 'src/main/java')
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() { |