Updated Branches: refs/heads/master c257ac859 -> b0632d439
Fixing STRATOS-420 Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/6d6ecbfe Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/6d6ecbfe Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/6d6ecbfe Branch: refs/heads/master Commit: 6d6ecbfe08e22af3f1f77208f2213e8dc51bcf2f Parents: 9052f26 Author: Isuru <[email protected]> Authored: Sat Feb 8 23:46:50 2014 +0530 Committer: Isuru <[email protected]> Committed: Sat Feb 8 23:46:50 2014 +0530 ---------------------------------------------------------------------- .../topology/receiver/StratosManagerTopologyReceiver.java | 8 ++++++++ 1 file changed, 8 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/6d6ecbfe/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyReceiver.java b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyReceiver.java index 30bc6e0..ff10a5c 100644 --- a/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyReceiver.java +++ b/components/org.apache.stratos.manager/src/main/java/org/apache/stratos/manager/topology/receiver/StratosManagerTopologyReceiver.java @@ -25,6 +25,7 @@ import org.apache.stratos.manager.retriever.DataInsertionAndRetrievalManager; import org.apache.stratos.manager.subscription.CartridgeSubscription; import org.apache.stratos.manager.topology.model.TopologyClusterInformationModel; import org.apache.stratos.messaging.domain.topology.Cluster; +import org.apache.stratos.messaging.domain.topology.Member; import org.apache.stratos.messaging.domain.topology.Service; import org.apache.stratos.messaging.event.Event; import org.apache.stratos.messaging.event.topology.*; @@ -331,6 +332,13 @@ public class StratosManagerTopologyReceiver implements Runnable { cluster = TopologyManager.getTopology(). getService(cartridgeSubscription.getType()).getCluster(cartridgeSubscription.getClusterDomain()); + // remove the terminated member from the cluster + Member terminatedMember = cluster.getMember(memberTerminatedEvent.getMemberId()); + cluster.removeMember(terminatedMember); + if (log.isDebugEnabled()) { + log.debug("Removed the terminated member with id " + memberTerminatedEvent.getMemberId() + " from the cluster"); + } + TopologyClusterInformationModel.getInstance().addCluster(cartridgeSubscription.getSubscriber().getTenantId(), cartridgeSubscription.getType(), cartridgeSubscription.getAlias(), cluster); }
