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

enable frame tracing in few more test cases

This commit is contained in:
Timothy Bish 2014-02-10 15:27:35 -05:00
parent cdfb562455
commit 301866d151
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
View File

@ -662,6 +662,7 @@ public class JMSClientTest extends AmqpTestSupport {
@Test(timeout=30000) @Test(timeout=30000)
public void testExecptionListenerCalledOnBrokerStop() throws Exception { public void testExecptionListenerCalledOnBrokerStop() throws Exception {
ActiveMQAdmin.enableJMSFrameTracing();
Connection connection = createConnection(); Connection connection = createConnection();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
@ -694,8 +695,9 @@ public class JMSClientTest extends AmqpTestSupport {
assertTrue("No exception listener event fired.", called.await(15, TimeUnit.SECONDS)); assertTrue("No exception listener event fired.", called.await(15, TimeUnit.SECONDS));
} }
@Test(timeout=40000) @Test(timeout=30000)
public void testSessionTransactedCommit() throws JMSException, InterruptedException { public void testSessionTransactedCommit() throws JMSException, InterruptedException {
ActiveMQAdmin.enableJMSFrameTracing();
Connection connection = createConnection(); Connection connection = createConnection();
Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE); Session session = connection.createSession(true, Session.AUTO_ACKNOWLEDGE);
@ -742,7 +744,7 @@ public class JMSClientTest extends AmqpTestSupport {
private Connection createConnection(String clientId, boolean syncPublish) throws JMSException { private Connection createConnection(String clientId, boolean syncPublish) throws JMSException {
final ConnectionFactoryImpl factory = new ConnectionFactoryImpl("localhost", port, "admin", "password"); final ConnectionFactoryImpl factory = new ConnectionFactoryImpl("localhost", nioPort, "admin", "password");
factory.setSyncPublish(syncPublish); factory.setSyncPublish(syncPublish);
factory.setTopicPrefix("topic://"); factory.setTopicPrefix("topic://");