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();