Skip to content
Snippets Groups Projects

Resolve "(UBI) Refactor Policy"

Merged Konstantinos Poulakakis requested to merge feat/112-ubi-refactor-policy into develop
All threads resolved!
1 file
+ 7
3
Compare changes
  • Side-by-side
  • Inline
@@ -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 =
Loading