Author: borges Date: 2011-07-22 10:00:43 -0400 (Fri, 22 Jul 2011) New Revision: 11028 Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java Log: test 'correction' Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java =================================================================== --- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java 2011-07-22 14:00:06 UTC (rev 11027) +++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ClusterWithBackupFailoverTestBase.java 2011-07-22 14:00:43 UTC (rev 11028) @@ -368,8 +368,8 @@ waitForBindings(2, QUEUES_TESTADDRESS, 1, 1, true); // live nodes - waitForBindings(1, QUEUES_TESTADDRESS, 1, 1, false); - waitForBindings(2, QUEUES_TESTADDRESS, 1, 1, false); + waitForBindings(1, QUEUES_TESTADDRESS, 2, 1, false); + waitForBindings(2, QUEUES_TESTADDRESS, 2, 1, false); send(1, QUEUES_TESTADDRESS, 10, false, null); verifyReceiveRoundRobinInSomeOrder(true, 10, 1, 2); @@ -385,7 +385,7 @@ waitForBindings(4, QUEUES_TESTADDRESS, 1, 1, true); // live nodes - waitForBindings(2, QUEUES_TESTADDRESS, 1, 1, false); + waitForBindings(2, QUEUES_TESTADDRESS, 2, 1, false); // activated backup nodes waitForBindings(4, QUEUES_TESTADDRESS, 1, 1, false); @@ -401,7 +401,7 @@ // live nodes waitForBindings(2, QUEUES_TESTADDRESS, 1, 1, true); // live nodes - waitForBindings(2, QUEUES_TESTADDRESS, 1, 0, false); + waitForBindings(2, QUEUES_TESTADDRESS, 2, 0, false); send(2, QUEUES_TESTADDRESS, 10, false, null); verifyReceiveRoundRobinInSomeOrder(true, 10, 2);