[hornetq-commits] JBoss hornetq SVN: r12136 - trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover.

[do-not-reply at jboss.org]

Author: ataylor
Date: 2012-02-17 10:03:28 -0500 (Fri, 17 Feb 2012)
New Revision: 12136

Modified:
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackManualTest.java
Log:
removed unneeded method from FailBackManualTest

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackManualTest.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackManualTest.java	2012-02-17 14:47:06 UTC (rev 12135)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailBackManualTest.java	2012-02-17 15:03:28 UTC (rev 12136)
@@ -89,7 +89,7 @@
 
       t.start();
 
-      waitForBackup(sf, 10);
+      waitForRemoteBackup(sf, 10, true, backupServer.getServer());
 
       assertTrue(backupServer.isStarted());
 
@@ -106,31 +106,6 @@
       Assert.assertEquals(0, sf.numConnections());
    }
 
-   protected void waitForBackup(ClientSessionFactoryInternal sf, int toWait)
-            throws Exception
-   {
-      long time = System.currentTimeMillis();
-      while (sf.getBackupConnector() == null)
-      {
-         try
-         {
-            Thread.sleep(100);
-         }
-         catch (InterruptedException e)
-         {
-            //ignore
-         }
-         if (sf.getBackupConnector() != null)
-         {
-            break;
-         }
-         else if (System.currentTimeMillis() > (time + toWait))
-         {
-            fail("backup server never started");
-         }
-      }
-      System.out.println("sf.getBackupConnector() = " + sf.getBackupConnector());
-   }
 
    @Override
    protected void createConfigs() throws Exception