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

[do-not-reply at jboss.org]

Author: borges
Date: 2011-11-04 05:13:03 -0400 (Fri, 04 Nov 2011)
New Revision: 11658

Modified:
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java
   trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
Log:
Delete unused inner classes

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java	2011-11-04 09:12:46 UTC (rev 11657)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java	2011-11-04 09:13:03 UTC (rev 11658)
@@ -15,7 +15,6 @@
 
 import java.util.ArrayList;
 import java.util.List;
-import java.util.concurrent.CountDownLatch;
 
 import junit.framework.Assert;
 
@@ -28,7 +27,6 @@
 import org.hornetq.api.core.client.ClientProducer;
 import org.hornetq.api.core.client.ClientSession;
 import org.hornetq.api.core.client.ServerLocator;
-import org.hornetq.api.core.client.SessionFailureListener;
 import org.hornetq.core.client.impl.ClientSessionFactoryInternal;
 import org.hornetq.core.client.impl.ClientSessionInternal;
 import org.hornetq.core.client.impl.DelegatingSession;
@@ -56,20 +54,6 @@
 
    private final Object lockFail = new Object();
 
-   class MyListener implements SessionFailureListener
-   {
-      CountDownLatch latch = new CountDownLatch(1);
-
-      public void connectionFailed(final HornetQException me, boolean failedOver)
-      {
-         latch.countDown();
-      }
-
-      public void beforeReconnect(final HornetQException me)
-      {
-      }
-   }
-
    public void testNonTransactional() throws Throwable
    {
       runTest(new TestRunner()

Modified: trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java
===================================================================
--- trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java	2011-11-04 09:12:46 UTC (rev 11657)
+++ trunk/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTestBase.java	2011-11-04 09:13:03 UTC (rev 11658)
@@ -25,7 +25,6 @@
 import junit.framework.Assert;
 
 import org.hornetq.api.core.HornetQBuffer;
-import org.hornetq.api.core.HornetQException;
 import org.hornetq.api.core.Pair;
 import org.hornetq.api.core.SimpleString;
 import org.hornetq.api.core.TransportConfiguration;
@@ -34,7 +33,6 @@
 import org.hornetq.api.core.client.ClusterTopologyListener;
 import org.hornetq.api.core.client.HornetQClient;
 import org.hornetq.api.core.client.ServerLocator;
-import org.hornetq.api.core.client.SessionFailureListener;
 import org.hornetq.core.client.impl.ClientSessionFactoryInternal;
 import org.hornetq.core.client.impl.ServerLocatorInternal;
 import org.hornetq.core.config.Configuration;
@@ -379,13 +377,6 @@
 
    // Inner classes -------------------------------------------------
 
-   abstract class BaseListener implements SessionFailureListener
-   {
-      public void beforeReconnect(final HornetQException me)
-      {
-      }
-   }
-
    class LatchClusterTopologyListener implements ClusterTopologyListener
    {
       final CountDownLatch latch;