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=369b2588b1a6046b04727b1403a01a1e8cf59934;hb=9fb9f6e4fe8eb9425d848ae576c0e755dfca22df;hp=5b5b4a8a785c291c1c694c5e4317bb21c6b7e9d1;hpb=4a7dd457d5b179dd0f588663fc1476dacfca4f22;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 5b5b4a8a..369b2588 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 @@ -23,6 +23,7 @@ package org.oransc.policyagent.repository; import java.util.HashMap; import java.util.Map; +import org.oransc.policyagent.exceptions.ServiceException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -34,4 +35,33 @@ public class Services { public Services() { } + public synchronized Service getService(String name) throws ServiceException { + Service s = services.get(name); + if (s == null) { + throw new ServiceException("Could not find service: " + name); + } + return s; + } + + public synchronized Service get(String name) { + return services.get(name); + } + + public synchronized void put(Service service) { + logger.debug("Put service: " + service.getName()); + services.put(service.getName(), service); + } + + public synchronized Iterable getAll() { + return services.values(); + } + + public synchronized void remove(String name) { + services.remove(name); + } + + public synchronized int size() { + return services.size(); + } + }