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;