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

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