[hornetq-commits] JBoss hornetq SVN: r10959 - branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-07-08 07:08:44 -0400 (Fri, 08 Jul 2011)
New Revision: 10959

Modified:
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java
Log:
Remove unused variables and unused imports.

Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java	2011-07-08 11:06:04 UTC (rev 10958)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java	2011-07-08 11:08:44 UTC (rev 10959)
@@ -41,7 +41,6 @@
 import org.hornetq.api.core.TransportConfiguration;
 import org.hornetq.api.core.client.ClientSessionFactory;
 import org.hornetq.api.core.client.HornetQClient;
-import org.hornetq.api.core.client.ServerLocator;
 import org.hornetq.core.asyncio.impl.AsynchronousFileImpl;
 import org.hornetq.core.client.impl.ClientSessionFactoryImpl;
 import org.hornetq.core.client.impl.ServerLocatorInternal;
@@ -83,7 +82,6 @@
 import org.hornetq.core.protocol.core.Channel;
 import org.hornetq.core.protocol.core.CoreRemotingConnection;
 import org.hornetq.core.protocol.core.impl.ChannelImpl.CHANNEL_ID;
-import org.hornetq.core.protocol.core.impl.wireformat.HaBackupRegistrationMessage;
 import org.hornetq.core.remoting.server.RemotingService;
 import org.hornetq.core.remoting.server.impl.RemotingServiceImpl;
 import org.hornetq.core.replication.ReplicationEndpoint;
@@ -555,14 +553,14 @@
                throw new RuntimeException("Need to retry...");
             }
             CoreRemotingConnection liveConnection = liveServerSessionFactory.getConnection();
-            Channel liveChannel = liveConnection.getChannel(CHANNEL_ID.PING.id, -1);
+            Channel pingChannel = liveConnection.getChannel(CHANNEL_ID.PING.id, -1);
             Channel replicationChannel = liveConnection.getChannel(CHANNEL_ID.REPLICATION.id, -1);
 
             replicationChannel.setHandler(replicationEndpoint);
             connectToReplicationEndpoint(replicationChannel);
             replicationEndpoint.start();
 
-            clusterManager.announceReplicatingBackup(liveChannel);
+            clusterManager.announceReplicatingBackup(pingChannel);
 
             log.info("HornetQ Backup Server version " + getVersion().getFullVersion() + " [" + nodeManager.getNodeId() +
                      "] started, waiting live to fail before it gets active");
@@ -612,8 +610,6 @@
 
    private Activation activation;
 
-   private ServerLocator serverLocator;
-
    public synchronized void start() throws Exception
    {
       initialiseLogging();