stratos-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From isu...@apache.org
Subject [1/2] git commit: re-adding the cluster removed listner at SM
Date Fri, 07 Feb 2014 03:33:58 GMT
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 <isuruh@wso2.com>
Authored: Fri Feb 7 01:19:17 2014 +0530
Committer: Isuru <isuruh@wso2.com>
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


Mime
View raw message