You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2015/01/26 17:26:20 UTC
qpid-jms git commit: reduce reconnect delays to something a bit more
reasonable for the test cases.
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 <ta...@gmail.com>
Authored: Mon Jan 26 11:25:57 2015 -0500
Committer: Timothy Bish <ta...@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