Commit b9d9ab9e authored by Tom Evans's avatar Tom Evans

OF-794: Cleanup sessions when node leaves cluster

Update session cleanup logic; execute anytime a node leaves the cluster,
regardless of "senior" status.
parent 72cd6e08
...@@ -44,6 +44,12 @@ ...@@ -44,6 +44,12 @@
Hazelcast Clustering Plugin Changelog Hazelcast Clustering Plugin Changelog
</h1> </h1>
<p><b>1.2.2</b> -- May 6, 2014</p>
<p>Bug Fix:</p>
<ul>
<li>Fix node cleanup logic when a node leaves the cluster (<a href="http://issues.igniterealtime.org/browse/OF-794">OF-794</a>)</li>
</ul>
<p><b>1.2.1</b> -- April 10, 2014</p> <p><b>1.2.1</b> -- April 10, 2014</p>
<p>Hazelcast update:</p> <p>Hazelcast update:</p>
<ul> <ul>
......
...@@ -5,7 +5,7 @@ ...@@ -5,7 +5,7 @@
<name>${plugin.name}</name> <name>${plugin.name}</name>
<description>${plugin.description}</description> <description>${plugin.description}</description>
<author>Tom Evans</author> <author>Tom Evans</author>
<version>1.2.1</version> <version>1.2.2</version>
<date>04/10/2014</date> <date>05/06/2014</date>
<minServerVersion>3.9.0</minServerVersion> <minServerVersion>3.9.0</minServerVersion>
</plugin> </plugin>
...@@ -640,10 +640,8 @@ public class ClusterListener implements MembershipListener, LifecycleListener { ...@@ -640,10 +640,8 @@ public class ClusterListener implements MembershipListener, LifecycleListener {
seniorClusterMember = true; seniorClusterMember = true;
ClusterManager.fireMarkedAsSeniorClusterMember(); ClusterManager.fireMarkedAsSeniorClusterMember();
} }
cleanupNode(NodeID.getInstance(nodeID));
if (CacheFactory.isSeniorClusterMember()) {
cleanupNode(NodeID.getInstance(nodeID));
}
// Remove traces of directed presences sent from local entities to handlers that no longer exist. // Remove traces of directed presences sent from local entities to handlers that no longer exist.
// At this point c2s sessions are gone from the routing table so we can identify expired sessions // At this point c2s sessions are gone from the routing table so we can identify expired sessions
XMPPServer.getInstance().getPresenceUpdateHandler().removedExpiredPresences(); XMPPServer.getInstance().getPresenceUpdateHandler().removedExpiredPresences();
......
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