Updated Branches:
  refs/heads/master e268ff886 -> fe32cc521

Terminate topology receiver thread if load balancer service component bundle is 
de-activated


Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/fe32cc52
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/fe32cc52
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/fe32cc52

Branch: refs/heads/master
Commit: fe32cc5215e03e4797ac7913f5b9265a72061f7b
Parents: e268ff8
Author: Imesh Gunaratne <[email protected]>
Authored: Sat Nov 23 19:31:05 2013 +0530
Committer: Imesh Gunaratne <[email protected]>
Committed: Sat Nov 23 19:31:05 2013 +0530

----------------------------------------------------------------------
 .../load/balancer/internal/LoadBalancerServiceComponent.java       | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/fe32cc52/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/internal/LoadBalancerServiceComponent.java
----------------------------------------------------------------------
diff --git 
a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/internal/LoadBalancerServiceComponent.java
 
b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/internal/LoadBalancerServiceComponent.java
index 2c8fe29..13ce1f0 100644
--- 
a/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/internal/LoadBalancerServiceComponent.java
+++ 
b/components/org.apache.stratos.load.balancer/src/main/java/org/apache/stratos/load/balancer/internal/LoadBalancerServiceComponent.java
@@ -153,6 +153,8 @@ public class LoadBalancerServiceComponent {
         } catch (Exception e) {
             log.warn("Couldn't remove the EndpointDeployer");
         }
+        // Terminate topology receiver
+        topologyReceiver.terminate();
     }
 
     /**

Reply via email to