X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fconfig%2Fconfig-util%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Futil%2FTestingConfigRegistry.java;h=8732aa72d127a8d95831e7b34a34e5e5bb01ff3b;hb=5c008222efa5c0af49cf8a52881a6299b1e249dc;hp=d4ae42d3de201c3102babd9e77e4e2b2918550d6;hpb=9fb64948564e252018f9b1e13e7cea2c92f991aa;p=controller.git diff --git a/opendaylight/config/config-util/src/test/java/org/opendaylight/controller/config/util/TestingConfigRegistry.java b/opendaylight/config/config-util/src/test/java/org/opendaylight/controller/config/util/TestingConfigRegistry.java index d4ae42d3de..8732aa72d1 100644 --- a/opendaylight/config/config-util/src/test/java/org/opendaylight/controller/config/util/TestingConfigRegistry.java +++ b/opendaylight/config/config-util/src/test/java/org/opendaylight/controller/config/util/TestingConfigRegistry.java @@ -7,12 +7,13 @@ */ package org.opendaylight.controller.config.util; +import com.google.common.collect.Sets; +import java.util.HashMap; import java.util.List; +import java.util.Map; import java.util.Set; - import javax.management.InstanceNotFoundException; import javax.management.ObjectName; - import org.opendaylight.controller.config.api.ConflictingVersionException; import org.opendaylight.controller.config.api.ModuleIdentifier; import org.opendaylight.controller.config.api.ValidationException; @@ -20,25 +21,34 @@ import org.opendaylight.controller.config.api.jmx.CommitStatus; import org.opendaylight.controller.config.api.jmx.ConfigRegistryMXBean; import org.opendaylight.controller.config.api.jmx.ObjectNameUtil; -import com.google.common.collect.Sets; - public class TestingConfigRegistry implements ConfigRegistryMXBean { static final ObjectName conf1, conf2, conf3, run1, run2, run3; + public static String check; + public static boolean checkBool; + private Map map = new HashMap<>(); public static final String moduleName1 = "moduleA"; public static final String moduleName2 = "moduleB"; public static final String instName1 = "instA"; public static final String instName2 = "instB"; + public static final String refName1 = "refA"; + public static final String refName2 = "refB"; + public static final String serviceQName1 = "qnameA"; + public static final String serviceQName2 = "qnameB"; static { conf1 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN + ":type=Module," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY - + "=" + moduleName1); + + "=" + moduleName1 + "," + ObjectNameUtil.SERVICE_QNAME_KEY + + "=" + serviceQName1 + "," + ObjectNameUtil.REF_NAME_KEY + + "=" + refName1); conf2 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN + ":type=Module," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY + "=" + moduleName1 + "," + ObjectNameUtil.INSTANCE_NAME_KEY - + "=" + instName1); + + "=" + instName1 + "," + ObjectNameUtil.SERVICE_QNAME_KEY + + "=" + serviceQName2 + "," + ObjectNameUtil.REF_NAME_KEY + + "=" + refName1); conf3 = ObjectNameUtil.createON(ObjectNameUtil.ON_DOMAIN + ":type=Module," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY + "=" + moduleName2 + "," + ObjectNameUtil.INSTANCE_NAME_KEY @@ -54,11 +64,15 @@ public class TestingConfigRegistry implements ConfigRegistryMXBean { + ":type=RuntimeBean," + ObjectNameUtil.MODULE_FACTORY_NAME_KEY + "=" + moduleName2 + "," + ObjectNameUtil.INSTANCE_NAME_KEY + "=" + instName2); + + check = null; + checkBool = false; + } @Override public ObjectName beginConfig() { - return null; + return conf2; } @Override @@ -143,4 +157,66 @@ public class TestingConfigRegistry implements ConfigRegistryMXBean { } } + @Override + public void checkConfigBeanExists(ObjectName objectName) throws InstanceNotFoundException { + Set configBeans = Sets. newHashSet(run1, run2, run3); + if(configBeans.size()>0){ + checkBool = true; + } + } + + @Override + public ObjectName lookupConfigBeanByServiceInterfaceName(String serviceInterfaceQName, String refName) { + if (serviceInterfaceQName.equals(serviceQName1) && refName.equals(refName1)) { + return conf1; + } + else{ + return null; + } + } + + @Override + public Map> getServiceMapping() { + return null; + } + + @Override + public Map lookupServiceReferencesByServiceInterfaceName(String serviceInterfaceQName) { + + if(serviceInterfaceQName.equals(serviceQName1)){ + map.put("conf1", conf1); + } + else if(serviceInterfaceQName.equals(serviceQName2)){ + map.put("conf2", conf2); + } + else{ + map.put("conf3", conf3); + } + return map; + } + + @Override + public Set lookupServiceInterfaceNames(ObjectName objectName) throws InstanceNotFoundException { + return Sets. newHashSet(serviceQName1, serviceQName2); + } + + @Override + public String getServiceInterfaceName(String namespace, String localName) { + return null; + } + + @Override + public Set getAvailableModuleFactoryQNames() { + return Sets. newHashSet(moduleName1, moduleName2); + } + + @Override + public ObjectName getServiceReference(String serviceInterfaceQName, String refName) throws InstanceNotFoundException { + return conf1; + } + + @Override + public void checkServiceReferenceExists(ObjectName objectName) throws InstanceNotFoundException { + throw new UnsupportedOperationException(); + } }