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

[do-not-reply at jboss.org]

Author: clebert.suconic at 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