Commit 976b7327 authored by Gaston Dombiak's avatar Gaston Dombiak Committed by gato

Moved responsibility of setting current nodeID.

git-svn-id: http://svn.igniterealtime.org/svn/repos/openfire/trunk@8354 b35dd754-fafc-0310-a699-88a17e54d16e
parent 9f16356a
...@@ -263,9 +263,9 @@ public class CacheFactory { ...@@ -263,9 +263,9 @@ public class CacheFactory {
return; return;
} }
// See if clustering should be enabled. // See if clustering should be enabled.
String enabled = JiveGlobals.getXMLProperty(CLUSTER_PROPERTY_NAME); boolean enabled = JiveGlobals.getXMLProperty(CLUSTER_PROPERTY_NAME, false);
if (Boolean.valueOf(enabled)) { if (enabled) {
Log.debug("Shutting down clustered cache service."); Log.debug("Shutting down clustered cache service.");
stopClustering(); stopClustering();
} }
...@@ -394,6 +394,9 @@ public class CacheFactory { ...@@ -394,6 +394,9 @@ public class CacheFactory {
} }
clusteringEnabled = true; clusteringEnabled = true;
// Set the ID of this cluster node
XMPPServer.getInstance().setNodeID(CacheFactory.getClusterMemberID());
// Fire event that cluster has been started
fireClusteringStarted(); fireClusteringStarted();
} }
} }
...@@ -423,9 +426,12 @@ public class CacheFactory { ...@@ -423,9 +426,12 @@ public class CacheFactory {
} }
clusteringEnabled = false; clusteringEnabled = false;
// Reset the node ID
XMPPServer.getInstance().setNodeID(null);
// Stop the cluster // Stop the cluster
clusteredFactory.stopCluster(); clusteredFactory.stopCluster();
// Fire event that cluster has been stopped
fireClusteringStopped(); fireClusteringStopped();
} }
catch (Exception e) { catch (Exception e) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment