[hornetq-commits] JBoss hornetq SVN: r10949 - 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-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();