Repository: qpid-jms Updated Branches: refs/heads/master 123990d4d -> d33ea1d54
NO-JIRA: Update broker ports used in the test to not clash with the ActiveMQ openwire default ports. Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/d33ea1d5 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/d33ea1d5 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/d33ea1d5 Branch: refs/heads/master Commit: d33ea1d542b6b363388f860a2e0f5996eefe4d97 Parents: 123990d Author: Timothy Bish <[email protected]> Authored: Tue May 12 10:09:08 2015 -0400 Committer: Timothy Bish <[email protected]> Committed: Tue May 12 10:09:08 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/qpid/jms/failover/JmsFailoverTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/d33ea1d5/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 80483da..5c88ede 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 @@ -62,7 +62,7 @@ public class JmsFailoverTest extends AmqpTestSupport { @Test(timeout=60000) public void testFailoverConnectsWithMultipleURIs() throws Exception { - URI brokerURI = new URI("failover://(amqp://127.0.0.1:61616,amqp://localhost:5777," + + URI brokerURI = new URI("failover://(amqp://127.0.0.1:5678,amqp://localhost:5777," + getBrokerAmqpConnectionURI() + ")?failover.useReconnectBackOff=false"); Connection connection = createAmqpConnection(brokerURI); connection.start(); @@ -71,7 +71,7 @@ public class JmsFailoverTest extends AmqpTestSupport { @Test(timeout=60000) public void testStartupReconnectAttempts() throws Exception { - URI brokerURI = new URI("failover://(amqp://localhost:61616)" + + URI brokerURI = new URI("failover://(amqp://localhost:5677)" + "?failover.startupMaxReconnectAttempts=5" + "&failover.useReconnectBackOff=false"); JmsConnectionFactory factory = new JmsConnectionFactory(brokerURI); @@ -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)" + + URI brokerURI = new URI("failover://(amqp://localhost:5678,amqp://localhost:5677)" + "?failover.startupMaxReconnectAttempts=6" + "&failover.useReconnectBackOff=false"); JmsConnectionFactory factory = new JmsConnectionFactory(brokerURI); @@ -215,7 +215,7 @@ public class JmsFailoverTest extends AmqpTestSupport { @Test(timeout=90000) public void testBadFirstURIConnectsAndProducerWorks() throws Exception { - URI brokerURI = new URI("failover://(amqp://localhost:61616," + getBrokerAmqpConnectionURI() + ")"); + URI brokerURI = new URI("failover://(amqp://localhost:5679," + getBrokerAmqpConnectionURI() + ")"); connection = createAmqpConnection(brokerURI); connection.start(); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
