X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fconfig%2Fthreadpool-config-impl%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fthreadpool%2Feventbus%2FSyncEventBusConfigBeanTest.java;fp=opendaylight%2Fconfig%2Fthreadpool-config-impl%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fconfig%2Fthreadpool%2Feventbus%2FSyncEventBusConfigBeanTest.java;h=0000000000000000000000000000000000000000;hb=c7e4aae58a1f4ce00e9ae06354290d1e5ceb0bab;hp=ed3ede01c6ecd2c9a6918b0c240fdebbab2895b5;hpb=b25f55c6265708661db0a43fccc595f7fdd81767;p=controller.git diff --git a/opendaylight/config/threadpool-config-impl/src/test/java/org/opendaylight/controller/config/threadpool/eventbus/SyncEventBusConfigBeanTest.java b/opendaylight/config/threadpool-config-impl/src/test/java/org/opendaylight/controller/config/threadpool/eventbus/SyncEventBusConfigBeanTest.java deleted file mode 100644 index ed3ede01c6..0000000000 --- a/opendaylight/config/threadpool-config-impl/src/test/java/org/opendaylight/controller/config/threadpool/eventbus/SyncEventBusConfigBeanTest.java +++ /dev/null @@ -1,103 +0,0 @@ -/* - * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved. - * - * This program and the accompanying materials are made available under the - * terms of the Eclipse Public License v1.0 which accompanies this distribution, - * and is available at http://www.eclipse.org/legal/epl-v10.html - */ -package org.opendaylight.controller.config.threadpool.eventbus; - -import static org.hamcrest.CoreMatchers.containsString; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertThat; -import static org.junit.Assert.fail; - -import javax.management.InstanceAlreadyExistsException; -import javax.management.ObjectName; -import org.junit.Before; -import org.junit.Test; -import org.opendaylight.controller.config.api.ConflictingVersionException; -import org.opendaylight.controller.config.api.ValidationException; -import org.opendaylight.controller.config.api.jmx.CommitStatus; -import org.opendaylight.controller.config.manager.impl.AbstractConfigTest; -import org.opendaylight.controller.config.manager.impl.factoriesresolver.HardcodedModuleFactoriesResolver; -import org.opendaylight.controller.config.util.ConfigTransactionJMXClient; -import org.opendaylight.controller.config.yang.threadpool.impl.EventBusModuleFactory; - -public class SyncEventBusConfigBeanTest extends AbstractConfigTest { - - private EventBusModuleFactory factory; - private final String instanceName = "sync1"; - - @Before - public void setUp() { - - factory = new EventBusModuleFactory(); - super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver(mockedContext,factory)); - } - - @Test - public void testCreateBean() throws InstanceAlreadyExistsException, ValidationException, - ConflictingVersionException { - ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction(); - - createSynced(transaction, instanceName); - transaction.validateConfig(); - CommitStatus status = transaction.commit(); - - assertEquals(1, configRegistry.lookupConfigBeans(factory.getImplementationName()).size()); - assertEquals(1, status.getNewInstances().size()); - assertEquals(0, status.getRecreatedInstances().size()); - assertEquals(0, status.getReusedInstances().size()); - // TODO test dead event collector - } - - @Test - public void testReusingOldInstance() throws InstanceAlreadyExistsException, ConflictingVersionException, - ValidationException { - - ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction(); - createSynced(transaction, instanceName); - - transaction.commit(); - - assertEquals(1, configRegistry.lookupConfigBeans(factory.getImplementationName()).size()); - - transaction = configRegistryClient.createTransaction(); - CommitStatus status = transaction.commit(); - - assertEquals(1, configRegistry.lookupConfigBeans(factory.getImplementationName()).size()); - assertEquals(0, status.getNewInstances().size()); - assertEquals(0, status.getRecreatedInstances().size()); - assertEquals(1, status.getReusedInstances().size()); - - } - - @Test - public void testInstanceAlreadyExistsException() throws ConflictingVersionException, ValidationException { - ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction(); - - try { - createSynced(transaction, instanceName); - transaction.commit(); - } catch (InstanceAlreadyExistsException e1) { - fail(); - } - - transaction = configRegistryClient.createTransaction(); - try { - createSynced(transaction, instanceName); - fail(); - } catch (InstanceAlreadyExistsException e) { - assertThat( - e.getMessage(), - containsString("There is an instance registered with name ModuleIdentifier{factoryName='eventbus', instanceName='sync1'}")); - } - } - - private ObjectName createSynced(ConfigTransactionJMXClient transaction, String instanceName) - throws InstanceAlreadyExistsException { - ObjectName nameCreated = transaction.createModule(factory.getImplementationName(), instanceName); - return nameCreated; - } -}