diff --git a/src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java b/src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java index 0d7117d4e4ab7548cd99a543200a8caaded4d43f..faf288cf637dcf8d567df46089c5eaf148a5921c 100644 --- a/src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java +++ b/src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java @@ -178,7 +178,7 @@ public class PolicyServiceImpl implements PolicyService { .onItem() .transform( isService -> - constructPolicyStateBasedOnCriteria( + constructPolicyStateBasedOnCriteria( isService, serviceId, policyRuleService, policyRuleBasic)); } @@ -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; } @@ -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 =