/*
- * Copyright (c) 2013 Cisco Systems, Inc. and others. All rights reserved.
+ * Copyright (c) 2013, 2017 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,
import static org.junit.Assert.assertThat;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+
import java.util.Map;
import javax.management.ObjectName;
import org.junit.After;
@Before
public void setUp() {
super.initConfigTransactionManagerImpl(new HardcodedModuleFactoriesResolver(mockedContext,
- new TestingFixedThreadPoolModuleFactory(),
- new TestingParallelAPSPModuleFactory()));
+ new TestingFixedThreadPoolModuleFactory(), new TestingParallelAPSPModuleFactory()));
}
@After
public void testDependencies() throws Exception {
ObjectName apspON;
{
- ConfigTransactionJMXClient transaction = configRegistryClient
- .createTransaction();
+ ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
// create fixed1
ObjectName threadPoolTransactionON = createFixed1(transaction,
TestingParallelAPSPImpl.MINIMAL_NUMBER_OF_THREADS);
// create apsp-parallel
- ObjectName apspNameTransactionON = createParallelAPSP(transaction,
- threadPoolTransactionON);
- TestingParallelAPSPConfigMXBean parallelAPSPConfigProxy = transaction
- .newMXBeanProxy(apspNameTransactionON, TestingParallelAPSPConfigMXBean.class);
+ ObjectName apspNameTransactionON = createParallelAPSP(transaction, threadPoolTransactionON);
+ TestingParallelAPSPConfigMXBean parallelAPSPConfigProxy = transaction.newMXBeanProxy(apspNameTransactionON,
+ TestingParallelAPSPConfigMXBean.class);
parallelAPSPConfigProxy.setSomeParam("");// trigger validation
- // failure
+ // failure
try {
transaction.validateConfig();
fail();
} catch (final ValidationException e) {
- for (Map.Entry<String, Map<String, ExceptionMessageWithStackTrace>> exception : e
- .getFailedValidations().entrySet()) {
- for (Map.Entry<String, ExceptionMessageWithStackTrace> entry : exception
- .getValue().entrySet()) {
- assertThat(
- entry.getValue().getMessage(),
- containsString("Parameter 'SomeParam' is blank"));
+ for (Map.Entry<String, Map<String, ExceptionMessageWithStackTrace>> exception : e.getFailedValidations()
+ .entrySet()) {
+ for (Map.Entry<String, ExceptionMessageWithStackTrace> entry : exception.getValue().entrySet()) {
+ assertThat(entry.getValue().getMessage(), containsString("Parameter 'SomeParam' is blank"));
}
}
}
transaction.commit();
fail();
} catch (final ValidationException e) {
- for (Map.Entry<String, Map<String, ExceptionMessageWithStackTrace>> exception : e
- .getFailedValidations().entrySet()) {
- for (Map.Entry<String, ExceptionMessageWithStackTrace> entry : exception
- .getValue().entrySet()) {
+ for (Map.Entry<String, Map<String, ExceptionMessageWithStackTrace>> exception : e.getFailedValidations()
+ .entrySet()) {
+ for (Map.Entry<String, ExceptionMessageWithStackTrace> entry : exception.getValue().entrySet()) {
String err = entry.getValue().getMessage();
- assertTrue("Unexpected error message: " + err,
- err.contains("Parameter 'SomeParam' is blank"));
+ assertTrue("Unexpected error message: " + err, err.contains("Parameter 'SomeParam' is blank"));
}
}
}
parallelAPSPConfigProxy.setSomeParam("abc");// fix validation
// failure
transaction.commit();
- apspON = ObjectNameUtil
- .withoutTransactionName(apspNameTransactionON);
+ apspON = ObjectNameUtil.withoutTransactionName(apspNameTransactionON);
}
// test reported apsp number of threads
- TestingParallelAPSPConfigMXBean parallelAPSPRuntimeProxy = configRegistryClient
- .newMXBeanProxy(apspON, TestingParallelAPSPConfigMXBean.class);
- assertEquals(
- (Integer) TestingParallelAPSPImpl.MINIMAL_NUMBER_OF_THREADS,
+ TestingParallelAPSPConfigMXBean parallelAPSPRuntimeProxy = configRegistryClient.newMXBeanProxy(apspON,
+ TestingParallelAPSPConfigMXBean.class);
+ assertEquals((Integer) TestingParallelAPSPImpl.MINIMAL_NUMBER_OF_THREADS,
parallelAPSPRuntimeProxy.getMaxNumberOfThreads());
// next transaction - recreate new thread pool
int newNumberOfThreads = TestingParallelAPSPImpl.MINIMAL_NUMBER_OF_THREADS * 2;
{
// start new transaction
- ConfigTransactionJMXClient transaction = configRegistryClient
- .createTransaction();
- ObjectName threadPoolNames_newTx = transaction.lookupConfigBean(
- getThreadPoolImplementationName(), fixed1);
+ ConfigTransactionJMXClient transaction = configRegistryClient.createTransaction();
+ ObjectName threadPoolNamesNewTx =
+ transaction.lookupConfigBean(getThreadPoolImplementationName(), fixed1);
TestingFixedThreadPoolConfigMXBean fixedConfigTransactionProxy = transaction
- .newMXBeanProxy(threadPoolNames_newTx, TestingFixedThreadPoolConfigMXBean.class);
+ .newMXBeanProxy(threadPoolNamesNewTx, TestingFixedThreadPoolConfigMXBean.class);
fixedConfigTransactionProxy.setThreadCount(newNumberOfThreads);
transaction.commit();
}
// new reference should be copied to apsp-parallel
- assertEquals((Integer) newNumberOfThreads,
- parallelAPSPRuntimeProxy.getMaxNumberOfThreads());
-
+ assertEquals((Integer) newNumberOfThreads, parallelAPSPRuntimeProxy.getMaxNumberOfThreads());
}
@Test
ObjectName threadPoolON = createFixed1(transaction, 10);
transaction.lookupConfigBean(getThreadPoolImplementationName(), fixed1);
String refName = "ref";
- ObjectName serviceReferenceON = transaction.saveServiceReference(TestingThreadPoolServiceInterface.QNAME, refName,
- threadPoolON);
+ ObjectName serviceReferenceON = transaction.saveServiceReference(TestingThreadPoolServiceInterface.QNAME,
+ refName, threadPoolON);
createParallelAPSP(transaction, serviceReferenceON);
transaction.commit();
-
}
}