[hornetq-commits] JBoss hornetq SVN: r11028 - branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover.

[do-not-reply at jboss.org]

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);