[hornetq-commits] JBoss hornetq SVN: r10919 - branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover.

[do-not-reply at jboss.org]

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 at 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;
    }