X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fconfig%2Fconfig-manager%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fmanager%2Ftestingservices%2Fparallelapsp%2Ftest%2FDependentWiringTest.java;h=f42b9559c4bb7e5a562aead7b7a60c0bc692602f;hb=0c931b8d1fa153991b10705a4358fe39f93181cd;hp=5b1a6f6e8184f69805ec5245e2d4b99089467e5d;hpb=9fb64948564e252018f9b1e13e7cea2c92f991aa;p=controller.git diff --git a/opendaylight/config/config-manager/src/test/java/org/opendaylight/controller/config/manager/testingservices/parallelapsp/test/DependentWiringTest.java b/opendaylight/config/config-manager/src/test/java/org/opendaylight/controller/config/manager/testingservices/parallelapsp/test/DependentWiringTest.java index 5b1a6f6e81..f42b9559c4 100644 --- a/opendaylight/config/config-manager/src/test/java/org/opendaylight/controller/config/manager/testingservices/parallelapsp/test/DependentWiringTest.java +++ b/opendaylight/config/config-manager/src/test/java/org/opendaylight/controller/config/manager/testingservices/parallelapsp/test/DependentWiringTest.java @@ -7,17 +7,6 @@ */ package org.opendaylight.controller.config.manager.testingservices.parallelapsp.test; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertThat; -import static org.junit.Assert.assertTrue; -import static org.junit.Assert.fail; -import static org.junit.internal.matchers.StringContains.containsString; - -import java.util.Map; - -import javax.management.ObjectName; - -import org.json.simple.JSONObject; import org.junit.After; import org.junit.Before; import org.junit.Test; @@ -32,7 +21,15 @@ import org.opendaylight.controller.config.manager.testingservices.threadpool.Tes import org.opendaylight.controller.config.manager.testingservices.threadpool.TestingFixedThreadPoolConfigMXBean; import org.opendaylight.controller.config.manager.testingservices.threadpool.TestingFixedThreadPoolModuleFactory; import org.opendaylight.controller.config.util.ConfigTransactionJMXClient; -import org.opendaylight.controller.config.util.jolokia.ConfigTransactionJolokiaClient; + +import javax.management.ObjectName; +import java.util.Map; + +import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertThat; +import static org.junit.Assert.assertTrue; +import static org.junit.Assert.fail; +import static org.junit.internal.matchers.StringContains.containsString; public class DependentWiringTest extends AbstractParallelAPSPTest { private final String fixed1 = "fixed1"; @@ -40,7 +37,7 @@ public class DependentWiringTest extends AbstractParallelAPSPTest { @Before public void setUp() { - super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver( + super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver(mockedContext, new TestingFixedThreadPoolModuleFactory(), new TestingParallelAPSPModuleFactory())); } @@ -51,7 +48,7 @@ public class DependentWiringTest extends AbstractParallelAPSPTest { } @Override - String getThreadPoolImplementationName() { + protected String getThreadPoolImplementationName() { return TestingFixedThreadPoolModuleFactory.NAME; } @@ -135,44 +132,4 @@ public class DependentWiringTest extends AbstractParallelAPSPTest { parallelAPSPRuntimeProxy.getMaxNumberOfThreads()); } - - @Test - public void testUsingJolokia() throws Exception { - - ConfigTransactionJolokiaClient transactionClient = configRegistryJolokiaClient - .createTransaction(); - // fixed1 - ObjectName fixed1ON = transactionClient.createModule( - getThreadPoolImplementationName(), fixed1); - transactionClient.setAttribute(fixed1ON, "ThreadCount", - TestingParallelAPSPImpl.MINIMAL_NUMBER_OF_THREADS); - - // apsp-parallel with syntetic attrib - String threadPoolString = "ThreadPool"; - ObjectName apsp1ON = transactionClient.createModule( - TestingParallelAPSPModuleFactory.NAME, apsp1); - transactionClient.setAttribute(apsp1ON, threadPoolString, fixed1ON); - // check - assertEquals(ObjectNameUtil.withoutTransactionName(fixed1ON), - transactionClient.getAttributeON(apsp1ON, threadPoolString)); - transactionClient.setAttribute(apsp1ON, "SomeParam", "ahoj"); - - // commit - transactionClient.commit(); - // check thread pool - assertEquals(1, TestingFixedThreadPool.allExecutors.size()); - // check platform MBeanServer - ObjectName apspReadOnlyON = ObjectNameUtil - .withoutTransactionName(apsp1ON); - JSONObject threadPoolONJson = (JSONObject) configRegistryJolokiaClient - .getAttribute(apspReadOnlyON, threadPoolString); - ObjectName fixed1ReadOnlyON = ObjectNameUtil - .withoutTransactionName(fixed1ON); - assertEquals(fixed1ReadOnlyON, ObjectNameUtil.createON(threadPoolONJson - .get("objectName").toString())); - assertEquals(fixed1ReadOnlyON, - configRegistryJolokiaClient.getAttributeON(apspReadOnlyON, - threadPoolString)); - - } }