[hornetq-commits] JBoss hornetq SVN: r10950 - 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:53:21 -0400 (Thu, 07 Jul 2011)
New Revision: 10950

Modified:
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java
Log:
HORNETQ-720 Set started to true earlier

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:39 UTC (rev 10949)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/server/impl/HornetQServerImpl.java	2011-07-07 13:53:21 UTC (rev 10950)
@@ -530,8 +530,8 @@
             clusterManager.start();
             // XXX this really belongs to this point?
             initialisePart2();
+            started = true;
 
-
             String liveConnectorName = configuration.getLiveConnectorName();
             if (liveConnectorName == null)
             {
@@ -560,8 +560,6 @@
 
             liveChannel.send(new HaBackupRegistrationMessage(getNodeID().toString(), config));
 
-            started = true;
-
             log.info("HornetQ Backup Server version " + getVersion().getFullVersion() + " [" + nodeManager.getNodeId() +
                      "] started, waiting live to fail before it gets active");
             nodeManager.awaitLiveNode();