X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=policy-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Foransc%2Fpolicyagent%2Frepository%2FServices.java;h=1c0e15aaeeec42601e36c4a4b158858fc5c6502b;hb=1178fb45f6d79fb3988b2806073aeeee3d68324e;hp=568f0029b26396653ccad87ad6f2da4d90e01864;hpb=444d11bb9de7be056d7609c395f3ef191c3c1702;p=nonrtric.git diff --git a/policy-agent/src/main/java/org/oransc/policyagent/repository/Services.java b/policy-agent/src/main/java/org/oransc/policyagent/repository/Services.java index 568f0029..1c0e15aa 100644 --- a/policy-agent/src/main/java/org/oransc/policyagent/repository/Services.java +++ b/policy-agent/src/main/java/org/oransc/policyagent/repository/Services.java @@ -22,6 +22,7 @@ package org.oransc.policyagent.repository; import java.util.HashMap; import java.util.Map; +import java.util.Vector; import org.oransc.policyagent.exceptions.ServiceException; import org.slf4j.Logger; @@ -46,11 +47,12 @@ public class Services { public synchronized void put(Service service) { logger.debug("Put service: {}", service.getName()); + service.keepAlive(); registeredServices.put(service.getName(), service); } public synchronized Iterable getAll() { - return registeredServices.values(); + return new Vector<>(registeredServices.values()); } public synchronized void remove(String name) { @@ -61,7 +63,7 @@ public class Services { return registeredServices.size(); } - public void clear() { + public synchronized void clear() { registeredServices.clear(); } }