+
+ // If recovery fails, try to remove all instances
+ deleteAllPolicies(ric);
+ Flux<PolicyType> recoverTypes = recoverPolicyTypes(ric);
+ Flux<?> deletePoliciesInRic = deleteAllPoliciesInRic(ric);
+
+ Flux.merge(recoverTypes, deletePoliciesInRic) //
+ .subscribe(x -> logger.debug("Brute recover: " + x), //
+ throwable -> onRemoveAllError(ric, throwable), //
+ () -> onRecoveryComplete(ric));
+ }
+
+ private void onRemoveAllError(Ric ric, Throwable t) {
+ logger.warn("Remove all failed for: {}, reason: {}", ric.name(), t.getMessage());