[hornetq-commits] JBoss hornetq SVN: r11002 - 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-19 07:53:21 -0400 (Tue, 19 Jul 2011)
New Revision: 11002

Modified:
   branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java
Log:
remove warnings

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-19 11:52:45 UTC (rev 11001)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/AsynchronousFailoverTest.java	2011-07-19 11:53:21 UTC (rev 11002)
@@ -30,10 +30,8 @@
 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;
 import org.hornetq.core.logging.Logger;
-import org.hornetq.spi.core.protocol.RemotingConnection;
 import org.hornetq.tests.util.TransportConfigurationUtils;
 
 /**
@@ -183,8 +181,6 @@
 
             createSession.createQueue(FailoverTestBase.ADDRESS, FailoverTestBase.ADDRESS, null, true);
 
-            RemotingConnection conn = ((ClientSessionInternal)createSession).getConnection();
-
             Thread t = new Thread(runnable);
 
             t.setName("MainTEST");
@@ -199,8 +195,6 @@
 
             AsynchronousFailoverTest.log.info("Failing asynchronously");
 
-            MyListener listener = this.listener;
-
             // Simulate failure on connection
             synchronized (lockFail)
             {