Author: borges Date: 2011-07-22 10:01:21 -0400 (Fri, 22 Jul 2011) New Revision: 11029 Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java Log: Fix test set-up Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java =================================================================== --- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java 2011-07-22 14:00:43 UTC (rev 11028) +++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java 2011-07-22 14:01:21 UTC (rev 11029) @@ -292,7 +292,7 @@ { e.printStackTrace(); } - Assert.assertEquals(e.getCode(), HornetQException.UNBLOCKED); + Assert.assertEquals("Expected UNBLOCKED", HornetQException.UNBLOCKED, e.getCode()); retry = true; } Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java =================================================================== --- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java 2011-07-22 14:00:43 UTC (rev 11028) +++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedAsynchronousFailoverTest.java 2011-07-22 14:01:21 UTC (rev 11029) @@ -20,36 +20,20 @@ * A ReplicatedAsynchronousFailoverTest * * @author <mailto:clebert.suconic@jboss.org">Clebert Suconic</a> - * - * */ public class ReplicatedAsynchronousFailoverTest extends AsynchronousFailoverTest { - // Constants ----------------------------------------------------- - - // Attributes ---------------------------------------------------- - - // Static -------------------------------------------------------- - - // Constructors -------------------------------------------------- - - // Public -------------------------------------------------------- - - // Package protected --------------------------------------------- - - // Protected ----------------------------------------------------- - @Override protected TestableServer createLiveServer() { - return new SameProcessHornetQServer(createServer(true, liveConfig)); + return new SameProcessHornetQServer(createInVMFailoverServer(true, liveConfig, nodeManager)); } @Override protected TestableServer createBackupServer() { - return new SameProcessHornetQServer(createServer(true, backupConfig)); + return new SameProcessHornetQServer(createInVMFailoverServer(true, backupConfig, nodeManager)); } @Override