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

AMQ-526: get TwoBrokerMulticastQueueTest to work. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@478558 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Frederick G. Oconer 2006-11-23 13:07:33 +00:00
parent e00678027f
commit d81997d3eb
2 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
activemq-core/pom.xml
View File

@ -230,7 +230,6 @@
<!-- m2 tests failing since move from assembly --> <!-- m2 tests failing since move from assembly -->
<exclude>**/TwoBrokerMulticastQueueTest.*</exclude>
<exclude>**/TwoBrokerMessageNotSentToRemoteWhenNoConsumerTest.*</exclude> <exclude>**/TwoBrokerMessageNotSentToRemoteWhenNoConsumerTest.*</exclude>
<exclude>**/TwoBrokerQueueClientsReconnectTest.*</exclude> <exclude>**/TwoBrokerQueueClientsReconnectTest.*</exclude>
<exclude>**/ThreeBrokerQueueNetworkUsingTcpTest.*</exclude> <exclude>**/ThreeBrokerQueueNetworkUsingTcpTest.*</exclude>

16
activemq-core/src/test/java/org/apache/activemq/usecases/TwoBrokerMulticastQueueTest.java
View File

@ -132,15 +132,15 @@ public class TwoBrokerMulticastQueueTest extends CombinationTestSupport {
} }
public void testSendReceiveUsingFailover() throws Exception { public void testSendReceiveUsingFailover() throws Exception {
sendUri = "failover:tcp://localhost:61616,tcp://localhost:61617"; sendUri = "failover:(tcp://localhost:61616,tcp://localhost:61617)";
recvUri = "failover:tcp://localhost:61616,tcp://localhost:61617"; recvUri = "failover:(tcp://localhost:61616,tcp://localhost:61617)";
createMulticastBrokerNetwork(); createMulticastBrokerNetwork();
doSendReceiveTest(); doSendReceiveTest();
} }
public void testMultipleConsumersConnectUsingFailover() throws Exception { public void testMultipleConsumersConnectUsingFailover() throws Exception {
sendUri = "failover:tcp://localhost:61616,tcp://localhost:61617"; sendUri = "failover:(tcp://localhost:61616,tcp://localhost:61617)";
recvUri = "failover:tcp://localhost:61616,tcp://localhost:61617"; recvUri = "failover:(tcp://localhost:61616,tcp://localhost:61617)";
createMulticastBrokerNetwork(); createMulticastBrokerNetwork();
doMultipleConsumersConnectTest(); doMultipleConsumersConnectTest();
} }
@ -160,15 +160,15 @@ public class TwoBrokerMulticastQueueTest extends CombinationTestSupport {
} }
public void testSendReceiveUsingAutoAssignFailover() throws Exception { public void testSendReceiveUsingAutoAssignFailover() throws Exception {
sendUri = "failover:multicast://default"; sendUri = "failover:(discovery:multicast://default)";
recvUri = "failover:multicast://default"; recvUri = "failover:(discovery:multicast://default)";
createAutoAssignMulticastBrokerNetwork(); createAutoAssignMulticastBrokerNetwork();
doSendReceiveTest(); doSendReceiveTest();
} }
public void testMultipleConsumersConnectUsingAutoAssignFailover() throws Exception { public void testMultipleConsumersConnectUsingAutoAssignFailover() throws Exception {
sendUri = "failover:multicast://default"; sendUri = "failover:(discovery:multicast://default)";
recvUri = "failover:multicast://default"; recvUri = "failover:(discovery:multicast://default)";
createAutoAssignMulticastBrokerNetwork(); createAutoAssignMulticastBrokerNetwork();
doMultipleConsumersConnectTest(); doMultipleConsumersConnectTest();
} }