activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject git commit: AMQ-5041 fix mistaken change of test to the nio port and revert ignored tests.
Date Tue, 11 Feb 2014 15:17:57 GMT
Updated Branches:
  refs/heads/trunk a165054df -> be6b4830e


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

Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/be6b4830
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/be6b4830
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/be6b4830

Branch: refs/heads/trunk
Commit: be6b4830ecf96e68d0523615b378b4a5c3f99ff8
Parents: a165054
Author: Timothy Bish <tabish121@gmai.com>
Authored: Tue Feb 11 10:17:49 2014 -0500
Committer: Timothy Bish <tabish121@gmai.com>
Committed: Tue Feb 11 10:17:49 2014 -0500

----------------------------------------------------------------------
 .../org/apache/activemq/transport/amqp/JMSClientTest.java | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/be6b4830/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
index 2e80e23..2d4df4f 100644
--- a/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
+++ b/activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
@@ -95,7 +95,6 @@ public class JMSClientTest extends AmqpTestSupport {
         connection.close();
     }
 
-    @Ignore("AMQ-5041")
     @Test
     public void testTransactedConsumer() throws Exception {
         ActiveMQAdmin.enableJMSFrameTracing();
@@ -127,7 +126,6 @@ public class JMSClientTest extends AmqpTestSupport {
         connection.close();
     }
 
-    @Ignore("AMQ-5041")
     @Test
     public void testRollbackRececeivedMessage() throws Exception {
 
@@ -172,7 +170,6 @@ public class JMSClientTest extends AmqpTestSupport {
         connection.close();
     }
 
-    @Ignore("AMQ-5041")
     @Test
     public void testTXConsumerAndLargeNumberOfMessages() throws Exception {
 
@@ -342,7 +339,6 @@ public class JMSClientTest extends AmqpTestSupport {
         }
     }
 
-    @Ignore("AMQ-5041")
     @Test(timeout=30000)
     public void testConsumerReceiveNoWaitThrowsWhenBrokerStops() throws Exception {
 
@@ -375,7 +371,6 @@ public class JMSClientTest extends AmqpTestSupport {
         }
     }
 
-    @Ignore("AMQ-5041")
     @Test(timeout=30000)
     public void testConsumerReceiveTimedThrowsWhenBrokerStops() throws Exception {
 
@@ -436,7 +431,6 @@ public class JMSClientTest extends AmqpTestSupport {
         }
     }
 
-    @Ignore("AMQ-5041")
     @Test(timeout=30000)
     public void testBrokerRestartWontHangConnectionClose() throws Exception {
 
@@ -461,7 +455,6 @@ public class JMSClientTest extends AmqpTestSupport {
         }
     }
 
-    @Ignore("AMQ-5041")
     @Test(timeout=120000)
     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));
     }
 
-    @Ignore("AMQ-5041")
     @Test(timeout=30000)
     public void testSessionTransactedCommit() throws JMSException, InterruptedException {
         ActiveMQAdmin.enableJMSFrameTracing();
@@ -762,7 +754,7 @@ public class JMSClientTest extends AmqpTestSupport {
 
     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.setTopicPrefix("topic://");


Mime
View raw message