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