[hornetq-commits] JBoss hornetq SVN: r9645 - branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover.

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2010-09-06 05:17:35 -0400 (Mon, 06 Sep 2010)
New Revision: 9645

Modified:
   branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
Log:
fix FailoverTest.testCreateNewFactoryAfterFailover

* set failover on initial connection on the server locator

Modified: branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
===================================================================
--- branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java	2010-09-06 08:19:17 UTC (rev 9644)
+++ branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTest.java	2010-09-06 09:17:35 UTC (rev 9645)
@@ -1354,7 +1354,7 @@
 
       locator.setBlockOnNonDurableSend(true);
       locator.setBlockOnDurableSend(true);
-      locator.setFailoverOnServerShutdown(true);
+      locator.setFailoverOnInitialConnection(true);
       ClientSessionFactoryInternal sf = createSessionFactoryAndWaitForTopology(locator, 2);
 
       ClientSession session = sendAndConsume(sf, true);
@@ -1363,7 +1363,7 @@
 
       session.close();
 
-      waitForBackup(5);
+      Thread.sleep(5000);
 
       sf = (ClientSessionFactoryInternal) locator.createSessionFactory();