Author: borges Date: 2011-07-07 06:22:56 -0400 (Thu, 07 Jul 2011) New Revision: 10945 Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java Log: HORNETQ-720 Start the replication end point before contacting the 'live' 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 10:22:25 UTC (rev 10944) +++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java 2011-07-07 10:22:56 UTC (rev 10945) @@ -553,6 +553,7 @@ 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); + replicationEndpoint.start(); liveChannel.send(new HaBackupRegistrationMessage(getNodeID().toString(), config)); @@ -566,6 +567,7 @@ // XXX this really belongs to this point? initialisePart2(); + configuration.setBackup(false); }