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=509b2f515bfd8fbbda94e55e7f529c6a478c7877;hb=9d0abfec77a4a040a3e5c86fe4f5a24a4847ebb9;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..509b2f51 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 @@ -20,9 +20,11 @@ package org.oransc.policyagent.repository; +import java.util.Collection; import java.util.HashMap; import java.util.Map; +import org.oransc.policyagent.exceptions.ServiceException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -34,4 +36,25 @@ 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 Collection getAll() { + return services.values(); + } + }