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=c10e0047dcaca890616a7afb043c50870b9e3702;hb=1f722deb1cd91420eed0add219ea749fec9d9912;hp=d4b32e022808e7226b8fbbff1204fcfe919972f3;hpb=e8c7fa0b02b0918b3b56a1fc162968a3eef282dc;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 d4b32e02..c10e0047 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.getName())) // + .doOnNext(service -> logger.info("Service is expired:" + service.name())) // .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.getName())); + return Flux.fromIterable(policies.getForService(service.name())); } }