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();
Show replies by date