Loading src/policy/src/main/java/org/etsi/tfs/policy/policy/kafka/AlarmListener.java +1 −1 Original line number Diff line number Diff line Loading @@ -40,7 +40,7 @@ public class AlarmListener { @Blocking public void receiveAlarm(AlarmTopicDTO alarmTopicDto) { logger.infof("Received message for analytic service backend :\n %s", alarmTopicDto.toString()); if (alarmTopicDto.isThresholdRaise()) { if (alarmTopicDto.isThresholdRaise() || alarmTopicDto.isThresholdFall()) { logger.infof("**************************Received Alarm!**************************"); logger.infof( "Received Alarm for analytic service backend with kpiId: %s", alarmTopicDto.getKpiId()); Loading src/policy/src/main/java/org/etsi/tfs/policy/policy/service/PolicyRuleConditionValidator.java +0 −3 Original line number Diff line number Diff line Loading @@ -79,14 +79,11 @@ public class PolicyRuleConditionValidator { Service service, ServiceId serviceId, List<String> deviceIds) { boolean checkIfServiceIdExists = checkIfServiceIdExists(service, serviceId); boolean checkIfServicesDeviceIdsExist = checkIfServicesDeviceIdsExist(service, deviceIds); LOGGER.info("checkIfServiceIdExists " + checkIfServiceIdExists); LOGGER.info("checkIfServicesDeviceIdsExist " + checkIfServicesDeviceIdsExist); return (checkIfServiceIdExists && checkIfServicesDeviceIdsExist); } private boolean checkIfServiceIdExists(Service service, ServiceId serviceId) { if (service == null) { LOGGER.info("service " + service); return false; } Loading Loading
src/policy/src/main/java/org/etsi/tfs/policy/policy/kafka/AlarmListener.java +1 −1 Original line number Diff line number Diff line Loading @@ -40,7 +40,7 @@ public class AlarmListener { @Blocking public void receiveAlarm(AlarmTopicDTO alarmTopicDto) { logger.infof("Received message for analytic service backend :\n %s", alarmTopicDto.toString()); if (alarmTopicDto.isThresholdRaise()) { if (alarmTopicDto.isThresholdRaise() || alarmTopicDto.isThresholdFall()) { logger.infof("**************************Received Alarm!**************************"); logger.infof( "Received Alarm for analytic service backend with kpiId: %s", alarmTopicDto.getKpiId()); Loading
src/policy/src/main/java/org/etsi/tfs/policy/policy/service/PolicyRuleConditionValidator.java +0 −3 Original line number Diff line number Diff line Loading @@ -79,14 +79,11 @@ public class PolicyRuleConditionValidator { Service service, ServiceId serviceId, List<String> deviceIds) { boolean checkIfServiceIdExists = checkIfServiceIdExists(service, serviceId); boolean checkIfServicesDeviceIdsExist = checkIfServicesDeviceIdsExist(service, deviceIds); LOGGER.info("checkIfServiceIdExists " + checkIfServiceIdExists); LOGGER.info("checkIfServicesDeviceIdsExist " + checkIfServicesDeviceIdsExist); return (checkIfServiceIdExists && checkIfServicesDeviceIdsExist); } private boolean checkIfServiceIdExists(Service service, ServiceId serviceId) { if (service == null) { LOGGER.info("service " + service); return false; } Loading