Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Reduce test time by disabling the unneeded broker features.

This commit is contained in:
Timothy Bish 2015-02-17 16:41:02 -05:00
parent 6e69319606
commit 141ad4cb8f
1 changed files with 17 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
activemq-unit-tests/src/test/java/org/apache/activemq/ActiveMQConnectionFactoryTest.java
View File

@ -41,7 +41,7 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
public void testUseURIToSetUseClientIDPrefixOnConnectionFactory() throws URISyntaxException, JMSException { public void testUseURIToSetUseClientIDPrefixOnConnectionFactory() throws URISyntaxException, JMSException {
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory( ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(
"vm://localhost?jms.clientIDPrefix=Cheese"); "vm://localhost?jms.clientIDPrefix=Cheese&broker.persistent=false");
assertEquals("Cheese", cf.getClientIDPrefix()); assertEquals("Cheese", cf.getClientIDPrefix());
connection = (ActiveMQConnection)cf.createConnection(); connection = (ActiveMQConnection)cf.createConnection();
@ -53,6 +53,12 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
assertTrue("should start with Cheese! but was: " + clientID, clientID.startsWith("Cheese")); assertTrue("should start with Cheese! but was: " + clientID, clientID.startsWith("Cheese"));
} }
@Override
public void setUp() throws Exception {
LOG.info("=========== Start test " + getName());
super.setUp();
}
@Override @Override
public void tearDown() throws Exception { public void tearDown() throws Exception {
// Try our best to close any previously opend connection. // Try our best to close any previously opend connection.
@ -65,6 +71,8 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
broker.stop(); broker.stop();
} catch (Throwable ignore) { } catch (Throwable ignore) {
} }
LOG.info("=========== Finished test " + getName());
} }
public void testUseURIToSetOptionsOnConnectionFactory() throws URISyntaxException, JMSException { public void testUseURIToSetOptionsOnConnectionFactory() throws URISyntaxException, JMSException {
@ -89,7 +97,7 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
public void testUseURIToConfigureRedeliveryPolicy() throws URISyntaxException, JMSException { public void testUseURIToConfigureRedeliveryPolicy() throws URISyntaxException, JMSException {
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory( ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(
"vm://localhost?jms.redeliveryPolicy.maximumRedeliveries=2"); "vm://localhost?broker.persistent=false&broker.useJmx=false&jms.redeliveryPolicy.maximumRedeliveries=2");
assertEquals("connection redeliveries", 2, cf.getRedeliveryPolicy().getMaximumRedeliveries()); assertEquals("connection redeliveries", 2, cf.getRedeliveryPolicy().getMaximumRedeliveries());
ActiveMQConnection connection = (ActiveMQConnection)cf.createConnection(); ActiveMQConnection connection = (ActiveMQConnection)cf.createConnection();
@ -103,7 +111,8 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
} }
public void testCreateVMConnectionWithEmbdeddBroker() throws URISyntaxException, JMSException { public void testCreateVMConnectionWithEmbdeddBroker() throws URISyntaxException, JMSException {
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://myBroker2?broker.persistent=false"); ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(
"vm://myBroker2?broker.persistent=false&broker.useJmx=false");
// Make sure the broker is not created until the connection is // Make sure the broker is not created until the connection is
// instantiated. // instantiated.
assertNull(BrokerRegistry.getInstance().lookup("myBroker2")); assertNull(BrokerRegistry.getInstance().lookup("myBroker2"));
@ -120,7 +129,8 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
} }
public void testGetBrokerName() throws URISyntaxException, JMSException { public void testGetBrokerName() throws URISyntaxException, JMSException {
ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"); ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory(
"vm://localhost?broker.persistent=false&broker.useJmx=false");
connection = (ActiveMQConnection)cf.createConnection(); connection = (ActiveMQConnection)cf.createConnection();
connection.start(); connection.start();
@ -141,6 +151,7 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
public void testCreateTcpConnectionUsingKnownLocalPort() throws Exception { public void testCreateTcpConnectionUsingKnownLocalPort() throws Exception {
broker = new BrokerService(); broker = new BrokerService();
broker.setPersistent(false); broker.setPersistent(false);
broker.setUseJmx(false);
broker.addConnector("tcp://localhost:61610?wireFormat.tcpNoDelayEnabled=true"); broker.addConnector("tcp://localhost:61610?wireFormat.tcpNoDelayEnabled=true");
broker.start(); broker.start();
@ -236,6 +247,8 @@ public class ActiveMQConnectionFactoryTest extends CombinationTestSupport {
broker = new BrokerService(); broker = new BrokerService();
broker.setPersistent(false); broker.setPersistent(false);
broker.setUseJmx(false); broker.setUseJmx(false);
broker.setAdvisorySupport(false);
broker.setSchedulerSupport(false);
TransportConnector connector = broker.addConnector(uri); TransportConnector connector = broker.addConnector(uri);
broker.start(); broker.start();