Loading src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java +7 −3 Original line number Diff line number Diff line Loading @@ -220,7 +220,10 @@ public class PolicyServiceImpl implements PolicyService { contextService .setPolicyRule(policyRule) .subscribe() .with(policyId -> startMonitoringBasedOnAlarmDescriptors(policyId, policyRuleService, alarmDescriptorList)); .with( policyId -> startMonitoringBasedOnAlarmDescriptors( policyId, policyRuleService, alarmDescriptorList)); return VALIDATED_POLICYRULE_STATE; } Loading Loading @@ -256,7 +259,8 @@ public class PolicyServiceImpl implements PolicyService { * @param policyRuleService the policy rule service * @return */ private List<Multi<AlarmResponse>> transformAlarmIds(List<Uni<String>> alarmIds, PolicyRuleService policyRuleService) { private List<Multi<AlarmResponse>> transformAlarmIds( List<Uni<String>> alarmIds, PolicyRuleService policyRuleService) { List<Multi<AlarmResponse>> alarmResponseStreamList = new ArrayList<>(); for (Uni<String> alarmId : alarmIds) { Multi<AlarmResponse> alarmResponseStream = Loading Loading
src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java +7 −3 Original line number Diff line number Diff line Loading @@ -220,7 +220,10 @@ public class PolicyServiceImpl implements PolicyService { contextService .setPolicyRule(policyRule) .subscribe() .with(policyId -> startMonitoringBasedOnAlarmDescriptors(policyId, policyRuleService, alarmDescriptorList)); .with( policyId -> startMonitoringBasedOnAlarmDescriptors( policyId, policyRuleService, alarmDescriptorList)); return VALIDATED_POLICYRULE_STATE; } Loading Loading @@ -256,7 +259,8 @@ public class PolicyServiceImpl implements PolicyService { * @param policyRuleService the policy rule service * @return */ private List<Multi<AlarmResponse>> transformAlarmIds(List<Uni<String>> alarmIds, PolicyRuleService policyRuleService) { private List<Multi<AlarmResponse>> transformAlarmIds( List<Uni<String>> alarmIds, PolicyRuleService policyRuleService) { List<Multi<AlarmResponse>> alarmResponseStreamList = new ArrayList<>(); for (Uni<String> alarmId : alarmIds) { Multi<AlarmResponse> alarmResponseStream = Loading