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

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2012-02-22 17:58:47 -0500 (Wed, 22 Feb 2012)
New Revision: 12165

Modified:
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackAutoTest.java
Log:
fixing test

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackAutoTest.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackAutoTest.java	2012-02-22 21:10:43 UTC (rev 12164)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackAutoTest.java	2012-02-22 22:58:47 UTC (rev 12165)
@@ -159,18 +159,15 @@
       locator.setFailoverOnInitialConnection(true);
       locator.setReconnectAttempts(-1);
       ClientSessionFactoryInternal sf = createSessionFactoryAndWaitForTopology(locator, 2);
-      CountDownLatch latch = new CountDownLatch(1);
-
+      
       ClientSession session = sendAndConsume(sf, true);
 
       CountDownSessionFailureListener listener = new CountDownSessionFailureListener();
 
       session.addFailureListener(listener);
 
-      liveServer.crash();
+      liveServer.crash(session);
 
-      assertTrue(latch.await(5, TimeUnit.SECONDS));
-
       ClientProducer producer = session.createProducer(FailoverTestBase.ADDRESS);
 
       ClientMessage message = session.createMessage(true);
@@ -279,7 +276,7 @@
 
       if (createQueue)
       {
-          session.createQueue(FailoverTestBase.ADDRESS, FailoverTestBase.ADDRESS, null, false);
+          session.createQueue(FailoverTestBase.ADDRESS, FailoverTestBase.ADDRESS, null, true);
       }
 
       ClientProducer producer = session.createProducer(FailoverTestBase.ADDRESS);