X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRicSupervision.java;fp=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FRepositorySupervision.java;h=d6013de733aa013b87f125669de176ad4e7544fd;hb=c5c251953f36a3a56613ad28f2d73f958ff58295;hp=22905f6ce044aaabc46fe91fabaacc347230cd1d;hpb=5606c08e8a5cc813a6a6eb09bacce123137e43e2;p=nonrtric.git

diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RepositorySupervision.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSupervision.java
similarity index 91%
rename from policy-agent/src/main/java/org/oransc/policyagent/tasks/RepositorySupervision.java
rename to policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSupervision.java
index 22905f6c..d6013de7 100644
--- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/RepositorySupervision.java
+++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/RicSupervision.java
@@ -47,8 +47,8 @@ import reactor.core.publisher.Mono;
  */
 @Component
 @EnableScheduling
-public class RepositorySupervision {
-    private static final Logger logger = LoggerFactory.getLogger(RepositorySupervision.class);
+public class RicSupervision {
+    private static final Logger logger = LoggerFactory.getLogger(RicSupervision.class);
 
     private final Rics rics;
     private final Policies policies;
@@ -57,7 +57,7 @@ public class RepositorySupervision {
     private final Services services;
 
     @Autowired
-    public RepositorySupervision(Rics rics, Policies policies, A1ClientFactory a1ClientFactory, PolicyTypes policyTypes,
+    public RicSupervision(Rics rics, Policies policies, A1ClientFactory a1ClientFactory, PolicyTypes policyTypes,
         Services services) {
         this.rics = rics;
         this.policies = policies;
@@ -72,7 +72,9 @@ public class RepositorySupervision {
     @Scheduled(fixedRate = 1000 * 60)
     public void checkAllRics() {
         logger.debug("Checking Rics starting");
-        createTask().subscribe(this::onRicChecked, null, this::onComplete);
+        createTask().subscribe(ric -> logger.debug("Ric: {} checked", ric.ric.name()), //
+            null, //
+            () -> logger.debug("Checking Rics completed"));
     }
 
     private Flux<RicData> createTask() {
@@ -163,15 +165,6 @@ public class RepositorySupervision {
         return Mono.error(new Exception("Syncronization started"));
     }
 
-    @SuppressWarnings("squid:S2629") // Invoke method(s) only conditionally
-    private void onRicChecked(RicData ric) {
-        logger.debug("Ric: {} checked", ric.ric.name());
-    }
-
-    private void onComplete() {
-        logger.debug("Checking Rics completed");
-    }
-
     RicSynchronizationTask createSynchronizationTask() {
         return new RicSynchronizationTask(a1ClientFactory, policyTypes, policies, services);
     }