qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject qpid-jms git commit: reduce reconnect delays to something a bit more reasonable for the test cases.
Date Mon, 26 Jan 2015 16:26:20 GMT
Repository: qpid-jms
Updated Branches:
  refs/heads/master 86247a117 -> 7a1d25d87


reduce reconnect delays to something a bit more reasonable for the test
cases. 

Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/7a1d25d8
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/7a1d25d8
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/7a1d25d8

Branch: refs/heads/master
Commit: 7a1d25d878fe2970a953701c57a76daf66082836
Parents: 86247a1
Author: Timothy Bish <tabish121@gmail.com>
Authored: Mon Jan 26 11:25:57 2015 -0500
Committer: Timothy Bish <tabish121@gmail.com>
Committed: Mon Jan 26 11:25:57 2015 -0500

----------------------------------------------------------------------
 .../org/apache/qpid/jms/failover/JmsFailoverTest.java     | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/7a1d25d8/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
----------------------------------------------------------------------
diff --git a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
index 64107d6..783c89a 100644
--- a/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
+++ b/qpid-jms-interop-tests/qpid-jms-activemq-tests/src/test/java/org/apache/qpid/jms/failover/JmsFailoverTest.java
@@ -72,7 +72,7 @@ public class JmsFailoverTest extends AmqpTestSupport {
     @Test(timeout=60000)
     public void testStartupReconnectAttempts() throws Exception {
         URI brokerURI = new URI("failover://(amqp://localhost:61616)" +
-                                "?maxReconnectDelay=1000&startupMaxReconnectAttempts=5");
+                                "?maxReconnectDelay=100&startupMaxReconnectAttempts=5");
         JmsConnectionFactory factory = new JmsConnectionFactory(brokerURI);
         Connection connection = factory.createConnection();
         try {
@@ -89,7 +89,7 @@ public class JmsFailoverTest extends AmqpTestSupport {
     @Test(timeout=60000)
     public void testStartupReconnectAttemptsMultipleHosts() throws Exception {
         URI brokerURI = new URI("failover://(amqp://localhost:61616,amqp://localhost:61617)"
+
-                                "?maxReconnectDelay=1000&startupMaxReconnectAttempts=5");
+                                "?maxReconnectDelay=100&startupMaxReconnectAttempts=5");
         JmsConnectionFactory factory = new JmsConnectionFactory(brokerURI);
         Connection connection = factory.createConnection();
         try {
@@ -105,7 +105,7 @@ public class JmsFailoverTest extends AmqpTestSupport {
 
     @Test(timeout=60000)
     public void testStartFailureWithAsyncExceptionListener() throws Exception {
-        URI brokerURI = new URI(getAmqpFailoverURI() + "?maxReconnectDelay=1000&maxReconnectAttempts=5");
+        URI brokerURI = new URI(getAmqpFailoverURI() + "?maxReconnectDelay=100&maxReconnectAttempts=5");
 
         final CountDownLatch failed = new CountDownLatch(1);
         JmsConnectionFactory factory = new JmsConnectionFactory(brokerURI);
@@ -158,7 +158,7 @@ public class JmsFailoverTest extends AmqpTestSupport {
     @SuppressWarnings("unused")
     @Test(timeout=60000)
     public void testDurableSubscriberRestores() throws Exception {
-        URI brokerURI = new URI(getAmqpFailoverURI() + "?maxReconnectDelay=1000");
+        URI brokerURI = new URI(getAmqpFailoverURI() + "?maxReconnectDelay=200");
 
         connection = createAmqpConnection(brokerURI);
         connection.setClientID(name.getMethodName());
@@ -200,7 +200,7 @@ public class JmsFailoverTest extends AmqpTestSupport {
     @Test(timeout=90000)
     public void testBadFirstURIConnectsAndProducerWorks() throws Exception {
         URI brokerURI = new URI("failover://(amqp://localhost:61616," +
-                                             getBrokerAmqpConnectionURI() + ")?maxReconnectDelay=1000");
+                                             getBrokerAmqpConnectionURI() + ")?maxReconnectDelay=100");
 
         connection = createAmqpConnection(brokerURI);
         connection.start();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message