[hornetq-commits] JBoss hornetq SVN: r11087 - branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution.

Author: clebert.suconic(a)jboss.com Date: 2011-08-01 10:25:18 -0400 (Mon, 01 Aug 2011) New Revision: 11087 Modified: branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterWithBackupTest.java Log: tweak for debug test Modified: branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterWithBackupTest.java =================================================================== --- branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterWithBackupTest.java 2011-08-01 13:51:31 UTC (rev 11086) +++ branches/Branch_2_2_EAP_cluster_clean2/tests/src/org/hornetq/tests/integration/cluster/distribution/ClusterWithBackupTest.java 2011-08-01 14:25:18 UTC (rev 11087) @@ -58,38 +58,47 @@ { return false; } - - public void testBasicRoundRobin() throws Exception + + public void testBasicRoundRobin() throws Throwable { - setupCluster(); - - startServers(0, 1, 2, 3, 4, 5); - - setupSessionFactory(3, isNetty()); - setupSessionFactory(4, isNetty()); - setupSessionFactory(5, isNetty()); - - createQueue(3, "queues.testaddress", "queue0", null, false); - createQueue(4, "queues.testaddress", "queue0", null, false); - createQueue(5, "queues.testaddress", "queue0", null, false); - - addConsumer(0, 3, "queue0", null); - addConsumer(1, 4, "queue0", null); - addConsumer(2, 5, "queue0", null); - - waitForBindings(3, "queues.testaddress", 1, 1, true); - waitForBindings(4, "queues.testaddress", 1, 1, true); - waitForBindings(5, "queues.testaddress", 1, 1, true); - - waitForBindings(3, "queues.testaddress", 2, 2, false); - waitForBindings(4, "queues.testaddress", 2, 2, false); - waitForBindings(5, "queues.testaddress", 2, 2, false); - - send(3, "queues.testaddress", 100, false, null); - - verifyReceiveRoundRobinInSomeOrder(100, 0, 1, 2); - - verifyNotReceive(0, 0, 1, 2); + try + { + setupCluster(); + + startServers(0, 1, 2, 3, 4, 5); + + setupSessionFactory(3, isNetty()); + setupSessionFactory(4, isNetty()); + setupSessionFactory(5, isNetty()); + + createQueue(3, "queues.testaddress", "queue0", null, false); + createQueue(4, "queues.testaddress", "queue0", null, false); + createQueue(5, "queues.testaddress", "queue0", null, false); + + addConsumer(0, 3, "queue0", null); + addConsumer(1, 4, "queue0", null); + addConsumer(2, 5, "queue0", null); + + waitForBindings(3, "queues.testaddress", 1, 1, true); + waitForBindings(4, "queues.testaddress", 1, 1, true); + waitForBindings(5, "queues.testaddress", 1, 1, true); + + waitForBindings(3, "queues.testaddress", 2, 2, false); + waitForBindings(4, "queues.testaddress", 2, 2, false); + waitForBindings(5, "queues.testaddress", 2, 2, false); + + send(3, "queues.testaddress", 100, false, null); + + verifyReceiveRoundRobinInSomeOrder(100, 0, 1, 2); + + verifyNotReceive(0, 0, 1, 2); + } + catch (Throwable e) + { + e.printStackTrace(); + log.error(e.getMessage(), e); + throw e; + } } protected void setupCluster() throws Exception