X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Ftasks%2FServiceSupervision.java;h=d4b32e022808e7226b8fbbff1204fcfe919972f3;hb=7dc42f177188d1e56da95d366d94a65d37b0cec6;hp=c10e0047dcaca890616a7afb043c50870b9e3702;hpb=c3ed1a5199e3f5f539cc813b9a383dd156fed2e2;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java b/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java index c10e0047..d4b32e02 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/tasks/ServiceSupervision.java @@ -72,7 +72,7 @@ public class ServiceSupervision { synchronized (services) { return Flux.fromIterable(services.getAll()) // .filter(service -> service.isExpired()) // - .doOnNext(service -> logger.info("Service is expired:" + service.name())) // + .doOnNext(service -> logger.info("Service is expired:" + service.getName())) // .flatMap(service -> getAllPolicies(service)) // .doOnNext(policy -> this.policies.remove(policy)) // .flatMap(policy -> deletePolicyInRic(policy)); @@ -81,7 +81,7 @@ public class ServiceSupervision { private Flux getAllPolicies(Service service) { synchronized (policies) { - return Flux.fromIterable(policies.getForService(service.name())); + return Flux.fromIterable(policies.getForService(service.getName())); } }