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

[do-not-reply at jboss.org]

Author: timfox
Date: 2010-04-16 05:30:02 -0400 (Fri, 16 Apr 2010)
New Revision: 9135

Modified:
   trunk/tests/src/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java
Log:
tweak to test

Modified: trunk/tests/src/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java	2010-04-16 05:53:35 UTC (rev 9134)
+++ trunk/tests/src/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java	2010-04-16 09:30:02 UTC (rev 9135)
@@ -415,8 +415,26 @@
                }
             }
 
-            ClientConsumer consumer = session.createConsumer(FailoverTestBase.ADDRESS);
-
+            ClientConsumer consumer = null;
+            
+            while (true)
+            {
+               try
+               {
+                  consumer = session.createConsumer(FailoverTestBase.ADDRESS);
+                  
+                  break;
+               }
+               catch (HornetQException e)
+               {
+                  if (e.getCode() == HornetQException.UNBLOCKED)
+                  {
+                     continue;
+                  }
+                  throw e;
+               }
+            }
+            
             session.start();
 
             int lastCount = -1;