[hornetq-commits] JBoss hornetq SVN: r10933 - 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-06 11:49:01 -0400 (Wed, 06 Jul 2011)
New Revision: 10933

Modified:
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java
Log:
HORNETQ-720 Add the replicationEndPoint handler to the replication channel

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-06 15:48:32 UTC (rev 10932)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java	2011-07-06 15:49:01 UTC (rev 10933)
@@ -546,11 +546,14 @@
                // XXX
                throw new RuntimeException("Need to retry...");
             }
-            log.info("announce backup to live-server (id=" + liveConnectorName + ")");
+            CoreRemotingConnection liveConnection = liveServerSessionFactory.getConnection();
+            Channel liveChannel = liveConnection.getChannel(CHANNEL_ID.PING.id, -1);
+            liveChannel.send(new HaBackupRegistrationMessage(getNodeID().toString(), config));
+            liveConnection.getChannel(CHANNEL_ID.REPLICATION.id, -1).setHandler(replicationEndpoint);
+
             liveServerSessionFactory.getConnection()
                                     .getChannel(CHANNEL_ID.PING.id, -1)
                                     .send(new HaBackupRegistrationMessage(getNodeID().toString(), config));
-            log.info("backup registered");
 
             started = true;
 
@@ -1952,8 +1955,6 @@
          return;
       JournalStorageManager journalStorageManager = (JournalStorageManager)storageManager;
 
-      System.out.println(HornetQServerImpl.class.getName() + " " + this.getIdentity() +
-               ": create a ReplicationManagerImpl");
       replicationManager = new ReplicationManagerImpl(rc, executorFactory);
       replicationManager.start();