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

AMQ-5041 fix mistaken change of test to the nio port and revert ignored 

tests.
This commit is contained in:
Timothy Bish 2014-02-11 10:17:49 -05:00
parent a165054df9
commit be6b4830ec
1 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -95,7 +95,6 @@ public class JMSClientTest extends AmqpTestSupport {
connection.close(); connection.close();
} }
@Ignore("AMQ-5041")
@Test @Test
public void testTransactedConsumer() throws Exception { public void testTransactedConsumer() throws Exception {
ActiveMQAdmin.enableJMSFrameTracing(); ActiveMQAdmin.enableJMSFrameTracing();
@ -127,7 +126,6 @@ public class JMSClientTest extends AmqpTestSupport {
connection.close(); connection.close();
} }
@Ignore("AMQ-5041")
@Test @Test
public void testRollbackRececeivedMessage() throws Exception { public void testRollbackRececeivedMessage() throws Exception {
@ -172,7 +170,6 @@ public class JMSClientTest extends AmqpTestSupport {
connection.close(); connection.close();
} }
@Ignore("AMQ-5041")
@Test @Test
public void testTXConsumerAndLargeNumberOfMessages() throws Exception { public void testTXConsumerAndLargeNumberOfMessages() throws Exception {
@ -342,7 +339,6 @@ public class JMSClientTest extends AmqpTestSupport {
} }
} }
@Ignore("AMQ-5041")
@Test(timeout=30000) @Test(timeout=30000)
public void testConsumerReceiveNoWaitThrowsWhenBrokerStops() throws Exception { public void testConsumerReceiveNoWaitThrowsWhenBrokerStops() throws Exception {
@ -375,7 +371,6 @@ public class JMSClientTest extends AmqpTestSupport {
} }
} }
@Ignore("AMQ-5041")
@Test(timeout=30000) @Test(timeout=30000)
public void testConsumerReceiveTimedThrowsWhenBrokerStops() throws Exception { public void testConsumerReceiveTimedThrowsWhenBrokerStops() throws Exception {
@ -436,7 +431,6 @@ public class JMSClientTest extends AmqpTestSupport {
} }
} }
@Ignore("AMQ-5041")
@Test(timeout=30000) @Test(timeout=30000)
public void testBrokerRestartWontHangConnectionClose() throws Exception { public void testBrokerRestartWontHangConnectionClose() throws Exception {
@ -461,7 +455,6 @@ public class JMSClientTest extends AmqpTestSupport {
} }
} }
@Ignore("AMQ-5041")
@Test(timeout=120000) @Test(timeout=120000)
public void testProduceAndConsumeLargeNumbersOfMessages() throws JMSException { public void testProduceAndConsumeLargeNumbersOfMessages() throws JMSException {
@ -712,7 +705,6 @@ 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));
} }
@Ignore("AMQ-5041")
@Test(timeout=30000) @Test(timeout=30000)
public void testSessionTransactedCommit() throws JMSException, InterruptedException { public void testSessionTransactedCommit() throws JMSException, InterruptedException {
ActiveMQAdmin.enableJMSFrameTracing(); ActiveMQAdmin.enableJMSFrameTracing();
@ -762,7 +754,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", nioPort, "admin", "password"); final ConnectionFactoryImpl factory = new ConnectionFactoryImpl("localhost", port, "admin", "password");
factory.setSyncPublish(syncPublish); factory.setSyncPublish(syncPublish);
factory.setTopicPrefix("topic://"); factory.setTopicPrefix("topic://");