Author: ataylor
Date: 2010-10-30 03:36:27 -0400 (Sat, 30 Oct 2010)
New Revision: 9823
Modified:
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
Log:
fixed failover test config
Modified:
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
===================================================================
---
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java 2010-10-30
00:06:04 UTC (rev 9822)
+++
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java 2010-10-30
07:36:27 UTC (rev 9823)
@@ -137,6 +137,9 @@
backupConfig.getConnectorConfigurations().put(backupConnector.getName(),
backupConnector);
ArrayList<String> staticConnectors = new ArrayList<String>();
staticConnectors.add(liveConnector.getName());
+ ClusterConnectionConfiguration cccLive = new
ClusterConnectionConfiguration("cluster1", "jms",
backupConnector.getName(), -1, false, false, 1, 1,
+ staticConnectors);
+ backupConfig.getClusterConfigurations().add(cccLive);
backupServer = createBackupServer();
// FIXME
@@ -254,7 +257,8 @@
sf = (ClientSessionFactoryInternal) locator.createSessionFactory();
- assertTrue(countDownLatch.await(5, TimeUnit.SECONDS));
+ boolean ok = countDownLatch.await(5, TimeUnit.SECONDS);
+ assertTrue(ok);
return sf;
}
Show replies by date