- Flux.concat(synchronizedTypes, deletePoliciesInRic) //
- .subscribe(x -> logger.debug("Brute recovery of failed synchronization: {}", x), //
- throwable -> onDeleteAllPolicyInstancesError(ric, throwable), //
- () -> onSynchronizationComplete(ric));
- }
-
- private void onDeleteAllPolicyInstancesError(Ric ric, Throwable t) {
- logger.warn("Synchronization failure recovery failed for ric: {}, reason: {}", ric.name(), t.getMessage());
- ric.setState(RicState.UNDEFINED);