[hornetq-commits] JBoss hornetq SVN: r9101 - trunk/tests/src/org/hornetq/tests/integration/cluster/restart.

[do-not-reply at jboss.org]

Author: timfox
Date: 2010-04-12 11:39:30 -0400 (Mon, 12 Apr 2010)
New Revision: 9101

Modified:
   trunk/tests/src/org/hornetq/tests/integration/cluster/restart/ClusterRestartTest.java
Log:
fixed clusterrestarttest

Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/restart/ClusterRestartTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/cluster/restart/ClusterRestartTest.java	2010-04-12 13:17:10 UTC (rev 9100)
+++ trunk/tests/src/org/hornetq/tests/integration/cluster/restart/ClusterRestartTest.java	2010-04-12 15:39:30 UTC (rev 9101)
@@ -76,12 +76,15 @@
          System.out.println("stopped******************************************************");
          startServers(0);
 
-         waitForBindings(0, "queues.testaddress", 1, 0, true);
-
+         
          addConsumer(1, 0, "queue10", null);
+         
+         waitForBindings(0, "queues.testaddress", 1, 1, true);
+         waitForBindings(1, "queues.testaddress", 1, 0, true);
 
          waitForBindings(0, "queues.testaddress", 1, 0, false);
          waitForBindings(1, "queues.testaddress", 1, 1, false);
+         
          printBindings(2);
 
          sendInRange(1, "queues.testaddress", 10, 20, false, null);
@@ -151,9 +154,10 @@
          startServers(0);
 
          waitForBindings(0, "queues.testaddress", 1, 0, true);
-
+         waitForBindings(1, "queues.testaddress", 1, 0, true);
          waitForBindings(0, "queues.testaddress", 1, 0, false);
          waitForBindings(1, "queues.testaddress", 1, 0, false);
+         
          printBindings(2);
          addConsumer(0, 1, "queue10", null);
          addConsumer(1, 0, "queue10", null);