[hornetq-commits] JBoss hornetq SVN: r10945 - branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl.
do-not-reply at jboss.org
do-not-reply at jboss.org
Thu Jul 7 06:22:56 EDT 2011
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);
}
More information about the hornetq-commits
mailing list