You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by re...@apache.org on 2014/10/17 13:30:45 UTC

git commit: starting cluster monitor thread

Repository: stratos
Updated Branches:
  refs/heads/4.0.0-grouping fa5a74120 -> 30a666571


starting cluster monitor thread


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

Branch: refs/heads/4.0.0-grouping
Commit: 30a6665711d85768fa57f1ee0e2013e499a925d7
Parents: fa5a741
Author: reka <rt...@gmail.com>
Authored: Fri Oct 17 17:00:33 2014 +0530
Committer: reka <rt...@gmail.com>
Committed: Fri Oct 17 17:00:33 2014 +0530

----------------------------------------------------------------------
 .../stratos/autoscaler/monitor/ApplicationMonitorFactory.java     | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/stratos/blob/30a66657/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ApplicationMonitorFactory.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ApplicationMonitorFactory.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ApplicationMonitorFactory.java
index 7cdf0cf..5f810d7 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ApplicationMonitorFactory.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/monitor/ApplicationMonitorFactory.java
@@ -63,6 +63,9 @@ public class ApplicationMonitorFactory {
             monitor = getGroupMonitor(context.getId(), appId);
         } else if (context instanceof ClusterContext) {
             monitor = getClusterMonitor((ClusterContext) context, appId);
+            //Start the thread
+            Thread th = new Thread((AbstractClusterMonitor)monitor);
+            th.start();
         } else {
             monitor = getApplicationMonitor(appId);
         }