diff options
Diffstat (limited to 'PolicyEngineAPI/src/test/java/org/onap/policy/std/test/DummyNotificationHandler.java')
| -rw-r--r-- | PolicyEngineAPI/src/test/java/org/onap/policy/std/test/DummyNotificationHandler.java | 182 |
1 files changed, 93 insertions, 89 deletions
diff --git a/PolicyEngineAPI/src/test/java/org/onap/policy/std/test/DummyNotificationHandler.java b/PolicyEngineAPI/src/test/java/org/onap/policy/std/test/DummyNotificationHandler.java index cdc717597..7cfe92541 100644 --- a/PolicyEngineAPI/src/test/java/org/onap/policy/std/test/DummyNotificationHandler.java +++ b/PolicyEngineAPI/src/test/java/org/onap/policy/std/test/DummyNotificationHandler.java @@ -4,12 +4,14 @@ * ================================================================================ * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved. * ================================================================================ + * Modifications Copyright (C) 2019 Samsung + * ================================================================================ * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at - * + * * http://www.apache.org/licenses/LICENSE-2.0 - * + * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. @@ -21,7 +23,6 @@ package org.onap.policy.std.test; import java.util.Collection; - import org.onap.policy.api.LoadedPolicy; import org.onap.policy.api.NotificationHandler; import org.onap.policy.api.NotificationType; @@ -35,92 +36,95 @@ import org.onap.policy.api.RemovedPolicy; import org.onap.policy.common.logging.flexlogger.FlexLogger; import org.onap.policy.common.logging.flexlogger.Logger; -public class DummyNotificationHandler implements NotificationHandler{ - - private static final Logger LOGGER = FlexLogger.getLogger(DummyNotificationHandler.class); - - @Override - public void notificationReceived(PDPNotification notification) { - System.out.println("Notification Received..."); - System.out.println(notification.getNotificationType()); - if(notification.getNotificationType().equals(NotificationType.REMOVE)){ - System.out.println("Removed Policies: \n"); - for(RemovedPolicy removedPolicy: notification.getRemovedPolicies()){ - System.out.println(removedPolicy.getPolicyName()); - System.out.println(removedPolicy.getVersionNo()); - } - }else if(notification.getNotificationType().equals(NotificationType.UPDATE)){ - System.out.println("Updated Policies: \n"); - for(LoadedPolicy updatedPolicy: notification.getLoadedPolicies()){ - System.out.println("policyName : " + updatedPolicy.getPolicyName()); - System.out.println("policyVersion :" + updatedPolicy.getVersionNo()); - if(updatedPolicy.getPolicyName().contains(".Config_")){ - System.out.println("Matches: " + updatedPolicy.getMatches()); - System.out.println("UpdateType: "+ updatedPolicy.getUpdateType()); - // Checking the Name is correct or not. - try { - PolicyEngine policyEngine = new PolicyEngine("config.properties"); - @SuppressWarnings("deprecation") - Collection<PolicyConfig> policyConfigs = policyEngine.getConfigByPolicyName(updatedPolicy.getPolicyName()); - for(PolicyConfig policyConfig: policyConfigs){ - if(policyConfig.getPolicyConfigStatus().equals(PolicyConfigStatus.CONFIG_RETRIEVED)){ - System.out.println("Policy Retrieved with this Name notified. "); - }else{ - System.err.println("\n\n Fail to retrieve policy !!!!\n\n"); - } - // Also Test this case. - if(policyConfig.getPolicyName().equals(updatedPolicy.getPolicyName())){ - System.out.println("Policy Name is good. "); - }else{ - System.err.println("\n\n Fail to check Name \n\n"); - } - } - } catch (PolicyEngineException e) { - LOGGER.error("Exception Occured"+e); - } catch (PolicyConfigException e) { - LOGGER.error("Exception Occured"+e); - } - } - } - }else if(notification.getNotificationType().equals(NotificationType.BOTH)){ - System.out.println("Both updated and Removed Notification: \n"); - System.out.println("Removed Policies: \n"); - for(RemovedPolicy removedPolicy: notification.getRemovedPolicies()){ - System.out.println(removedPolicy.getPolicyName()); - System.out.println(removedPolicy.getVersionNo()); - } - System.out.println("Updated Policies: \n"); - for(LoadedPolicy updatedPolicy: notification.getLoadedPolicies()){ - System.out.println("policyName : " + updatedPolicy.getPolicyName()); - System.out.println("policyVersion :" + updatedPolicy.getVersionNo()); - System.out.println("Matches: " + updatedPolicy.getMatches()); - System.out.println("UpdateType: "+ updatedPolicy.getUpdateType()); - // Checking the Name is correct or not. - try { - PolicyEngine policyEngine = new PolicyEngine("config.properties"); - @SuppressWarnings("deprecation") - Collection<PolicyConfig> policyConfigs = policyEngine.getConfigByPolicyName(updatedPolicy.getPolicyName()); - for(PolicyConfig policyConfig: policyConfigs){ - if(policyConfig.getPolicyConfigStatus().equals(PolicyConfigStatus.CONFIG_RETRIEVED)){ - System.out.println("Policy Retrieved with this Name notified. "); - }else{ - System.err.println("\n\n Fail to retrieve policy !!!!\n\n"); - } - // Also Test this case. - if(policyConfig.getPolicyName().equals(updatedPolicy.getPolicyName())){ - System.out.println("Policy Name is good. "); - }else{ - System.err.println("\n\n Fail to check Name \n\n"); - } - } - } catch (PolicyEngineException e) { - LOGGER.error("Exception Occured"+e); - } catch (PolicyConfigException e) { - LOGGER.error("Exception Occured"+e); - } - } - } - } +public class DummyNotificationHandler implements NotificationHandler { + private static final Logger LOGGER = FlexLogger.getLogger(DummyNotificationHandler.class); + @Override + public void notificationReceived(PDPNotification notification) { + System.out.println("Notification Received..."); + System.out.println(notification.getNotificationType()); + if (notification.getNotificationType().equals(NotificationType.REMOVE)) { + System.out.println("Removed Policies: \n"); + for (RemovedPolicy removedPolicy : notification.getRemovedPolicies()) { + System.out.println(removedPolicy.getPolicyName()); + System.out.println(removedPolicy.getVersionNo()); + } + } else if (notification.getNotificationType().equals(NotificationType.UPDATE)) { + System.out.println("Updated Policies: \n"); + for (LoadedPolicy updatedPolicy : notification.getLoadedPolicies()) { + System.out.println("policyName : " + updatedPolicy.getPolicyName()); + System.out.println("policyVersion :" + updatedPolicy.getVersionNo()); + if (updatedPolicy.getPolicyName().contains(".Config_")) { + System.out.println("Matches: " + updatedPolicy.getMatches()); + System.out.println("UpdateType: " + updatedPolicy.getUpdateType()); + // Checking the Name is correct or not. + try { + PolicyEngine policyEngine = new PolicyEngine("config.properties"); + @SuppressWarnings("deprecation") + Collection<PolicyConfig> policyConfigs = + policyEngine.getConfigByPolicyName(updatedPolicy.getPolicyName()); + for (PolicyConfig policyConfig : policyConfigs) { + if (policyConfig.getPolicyConfigStatus() + .equals(PolicyConfigStatus.CONFIG_RETRIEVED)) { + System.out.println("Policy Retrieved with this Name notified. "); + } else { + System.err.println("\n\n Fail to retrieve policy !!!!\n\n"); + } + // Also Test this case. + if (policyConfig.getPolicyName() + .equals(updatedPolicy.getPolicyName())) { + System.out.println("Policy Name is good. "); + } else { + System.err.println("\n\n Fail to check Name \n\n"); + } + } + } catch (PolicyEngineException e) { + LOGGER.error("Exception Occured" + e); + } catch (PolicyConfigException e) { + LOGGER.error("Exception Occured" + e); + } + } + } + } else if (notification.getNotificationType().equals(NotificationType.BOTH)) { + System.out.println("Both updated and Removed Notification: \n"); + System.out.println("Removed Policies: \n"); + for (RemovedPolicy removedPolicy : notification.getRemovedPolicies()) { + System.out.println(removedPolicy.getPolicyName()); + System.out.println(removedPolicy.getVersionNo()); + } + System.out.println("Updated Policies: \n"); + for (LoadedPolicy updatedPolicy : notification.getLoadedPolicies()) { + System.out.println("policyName : " + updatedPolicy.getPolicyName()); + System.out.println("policyVersion :" + updatedPolicy.getVersionNo()); + System.out.println("Matches: " + updatedPolicy.getMatches()); + System.out.println("UpdateType: " + updatedPolicy.getUpdateType()); + // Checking the Name is correct or not. + try { + PolicyEngine policyEngine = new PolicyEngine("config.properties"); + @SuppressWarnings("deprecation") + Collection<PolicyConfig> policyConfigs = + policyEngine.getConfigByPolicyName(updatedPolicy.getPolicyName()); + for (PolicyConfig policyConfig : policyConfigs) { + if (policyConfig.getPolicyConfigStatus() + .equals(PolicyConfigStatus.CONFIG_RETRIEVED)) { + System.out.println("Policy Retrieved with this Name notified. "); + } else { + System.err.println("\n\n Fail to retrieve policy !!!!\n\n"); + } + // Also Test this case. + if (policyConfig.getPolicyName().equals(updatedPolicy.getPolicyName())) { + System.out.println("Policy Name is good. "); + } else { + System.err.println("\n\n Fail to check Name \n\n"); + } + } + } catch (PolicyEngineException e) { + LOGGER.error("Exception Occured" + e); + } catch (PolicyConfigException e) { + LOGGER.error("Exception Occured" + e); + } + } + } + } } |