removing blocking while loop

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

Branch: refs/heads/master
Commit: 976cf56308a7103f2194c04a0a9b915e3e335299
Parents: 3f45f63
Author: reka <[email protected]>
Authored: Wed Dec 3 14:38:28 2014 +0530
Committer: reka <[email protected]>
Committed: Wed Dec 3 14:38:28 2014 +0530

----------------------------------------------------------------------
 .../receiver/health/stat/HealthStatEventReceiver.java        | 8 --------
 1 file changed, 8 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/stratos/blob/976cf563/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java
----------------------------------------------------------------------
diff --git 
a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java
 
b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java
index d324c7e..0253704 100644
--- 
a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java
+++ 
b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java
@@ -67,14 +67,6 @@ public class HealthStatEventReceiver {
                        if (log.isDebugEnabled()) {
                                log.debug("Health stats event message delegator 
thread started");
                        }
-
-                       // Keep the thread live until terminated
-                       while (!terminated) {
-                               try {
-                                       Thread.sleep(1000);
-                               } catch (InterruptedException ignore) {
-                               }
-                       }
                } catch (Exception e) {
                        if (log.isErrorEnabled()) {
                                log.error("Topology receiver failed", e);

Reply via email to