Author: borges Date: 2011-07-05 10:56:11 -0400 (Tue, 05 Jul 2011) New Revision: 10919 Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java Log: Set clustered=true on each node configuration. Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java =================================================================== --- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java 2011-07-05 14:51:49 UTC (rev 10918) +++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java 2011-07-05 14:56:11 UTC (rev 10919) @@ -48,9 +48,9 @@ import org.hornetq.tests.util.RandomUtil; /** - * + * * A FailoverTest - * + * * @author <a href="mailto:tim.fox@jboss.com">Tim Fox</a> * */ @@ -2424,7 +2424,7 @@ /** * @param i * @param message - * @throws Exception + * @throws Exception */ protected void setBody(final int i, final ClientMessage message) throws Exception { Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java =================================================================== --- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java 2011-07-05 14:51:49 UTC (rev 10918) +++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java 2011-07-05 14:56:11 UTC (rev 10919) @@ -176,6 +176,7 @@ config1.setSharedStore(false); config1.setBackup(true); config1.setLiveConnectorName(LIVE_NODE_NAME); + config1.setClustered(true); backupConfig = config1; backupServer = createBackupServer(); @@ -187,6 +188,7 @@ config0.setName(LIVE_NODE_NAME); config0.setSecurityEnabled(false); config0.setSharedStore(false); + config0.setClustered(true); liveConfig = config0; liveServer = createLiveServer(); liveServer.getServer().setIdentity("id_live"); @@ -245,8 +247,7 @@ sf = (ClientSessionFactoryInternal) locator.createSessionFactory(); - boolean ok = countDownLatch.await(5, TimeUnit.SECONDS); - assertTrue(ok); + assertTrue("topology members expected " + topologyMembers, countDownLatch.await(5, TimeUnit.SECONDS)); return sf; }