X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRicSynchronizationTask.java;h=19036efb141c6b55e584c5d8b6f8f9bbe56cfc08;hb=9033316e83ab3927034ed0380d048648813caaab;hp=a664b26cfb04408084a5c0ca88d962a1717958bb;hpb=af0bd57583b2ea2b408b9fa1ca7c0c36e4a45757;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java index a664b26c..19036efb 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSynchronizationTask.java @@ -137,7 +137,7 @@ public class RicSynchronizationTask { .doOnComplete(() -> deleteAllPoliciesInRepository(ric)); Flux.concat(recoverTypes, deletePoliciesInRic) // - .subscribe(x -> logger.debug("Brute recover: ", x), // + .subscribe(x -> logger.debug("Brute recover: {}", x), // throwable -> onRecoveryError(ric, throwable), // () -> onSynchronizationComplete(ric)); }