Author: borges Date: 2011-07-07 09:11:39 -0400 (Thu, 07 Jul 2011) New Revision: 10949 Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java Log: HORNETQ-720 Fix snafu: send HaBackupRegistration only once! 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-07 13:11:07 UTC (rev 10948) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java 2011-07-07 13:11:39 UTC (rev 10949) @@ -552,8 +552,8 @@ } CoreRemotingConnection liveConnection = liveServerSessionFactory.getConnection(); Channel liveChannel = liveConnection.getChannel(CHANNEL_ID.PING.id, -1); - liveChannel.send(new HaBackupRegistrationMessage(getNodeID().toString(), config)); Channel replicationChannel = liveConnection.getChannel(CHANNEL_ID.REPLICATION.id, -1); + replicationChannel.setHandler(replicationEndpoint); connectToReplicationEndpoint(replicationChannel); replicationEndpoint.start();