Author: borges Date: 2011-07-13 11:31:38 -0400 (Wed, 13 Jul 2011) New Revision: 10974 Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java Log: Clean up 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-13 06:13:31 UTC (rev 10973) +++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java 2011-07-13 15:31:38 UTC (rev 10974) @@ -1639,11 +1639,9 @@ public void testBackupServerNotRemoved() throws Exception { - locator.setBlockOnNonDurableSend(true); - locator.setBlockOnDurableSend(true); locator.setFailoverOnInitialConnection(true); - locator.setReconnectAttempts(-1); - sf = createSessionFactoryAndWaitForTopology(locator, 2); + createSessionFactory(); + final CountDownLatch latch = new CountDownLatch(1); class MyListener implements SessionFailureListener @@ -1689,11 +1687,8 @@ public void testLiveAndBackupLiveComesBack() throws Exception { - locator.setBlockOnNonDurableSend(true); - locator.setBlockOnDurableSend(true); locator.setFailoverOnInitialConnection(true); - locator.setReconnectAttempts(-1); - sf = createSessionFactoryAndWaitForTopology(locator, 2); + createSessionFactory(); final CountDownLatch latch = new CountDownLatch(1); class MyListener implements SessionFailureListener @@ -1741,11 +1736,9 @@ public void testLiveAndBackupLiveComesBackNewFactory() throws Exception { - locator.setBlockOnNonDurableSend(true); - locator.setBlockOnDurableSend(true); locator.setFailoverOnInitialConnection(true); - locator.setReconnectAttempts(-1); - sf = createSessionFactoryAndWaitForTopology(locator, 2); + createSessionFactory(); + final CountDownLatch latch = new CountDownLatch(1); class MyListener implements SessionFailureListener