Updated Branches: refs/heads/master 4e8c0cc23 -> ccac18739
re-adding the cluster removed listner at SM Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/1367eeed Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/1367eeed Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/1367eeed Branch: refs/heads/master Commit: 1367eeedb5147f24a7c3f82fbfd9d45b9acb5767 Parents: 4e8c0cc Author: Isuru <[email protected]> Authored: Fri Feb 7 01:19:17 2014 +0530 Committer: Isuru <[email protected]> Committed: Fri Feb 7 01:19:17 2014 +0530 ---------------------------------------------------------------------- .../StratosManagerTopologyReceiver.java | 44 ++++++++++---------- 1 file changed, 22 insertions(+), 22 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/1367eeed/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 6c90c35..e23b2d4 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 @@ -128,28 +128,28 @@ public class StratosManagerTopologyReceiver implements Runnable { }); //Cluster Removed event listner -// processorChain.addEventListener(new ClusterRemovedEventListener() { -// @Override -// protected void onEvent(Event event) { -// -// log.info("********** [ClusterRemovedEventListener] Received: " + event.getClass() + " **********"); -// -// ClusterRemovedEvent clusterRemovedEvent = (ClusterRemovedEvent) event; -// -// Set<CartridgeSubscription> cartridgeSubscriptions = -// getCartridgeSubscription(clusterRemovedEvent.getClusterId()); -// -// if(cartridgeSubscriptions != null) { -// -// // iterate -// for (CartridgeSubscription cartridgeSubscription : cartridgeSubscriptions) { -// //add the information to Topology Cluster Info. model -// TopologyClusterInformationModel.getInstance().removeCluster(cartridgeSubscription.getSubscriber().getTenantId(), -// cartridgeSubscription.getType(), cartridgeSubscription.getAlias()); -// } -// } -// } -// }); + processorChain.addEventListener(new ClusterRemovedEventListener() { + @Override + protected void onEvent(Event event) { + + log.info("********** [ClusterRemovedEventListener] Received: " + event.getClass() + " **********"); + + ClusterRemovedEvent clusterRemovedEvent = (ClusterRemovedEvent) event; + + Set<CartridgeSubscription> cartridgeSubscriptions = + getCartridgeSubscription(clusterRemovedEvent.getClusterId()); + + if(cartridgeSubscriptions != null) { + + // iterate + for (CartridgeSubscription cartridgeSubscription : cartridgeSubscriptions) { + //add the information to Topology Cluster Info. model + TopologyClusterInformationModel.getInstance().removeCluster(cartridgeSubscription.getSubscriber().getTenantId(), + cartridgeSubscription.getType(), cartridgeSubscription.getAlias()); + } + } + } + }); //Instance Spawned event listner
