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