You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by la...@apache.org on 2014/01/09 14:41:01 UTC
git commit: Initialize health stat receiver in constructor
Updated Branches:
refs/heads/master df1e7fd1a -> 9a6c7156a
Initialize health stat receiver in constructor
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/9a6c7156
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/9a6c7156
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/9a6c7156
Branch: refs/heads/master
Commit: 9a6c7156ac82f9e7ee31a1f6c02a5ceac53d769a
Parents: df1e7fd
Author: Lahiru Sandaruwan <la...@apache.org>
Authored: Thu Jan 9 19:15:23 2014 +0530
Committer: Lahiru Sandaruwan <la...@apache.org>
Committed: Thu Jan 9 19:15:23 2014 +0530
----------------------------------------------------------------------
.../receiver/health/AutoscalerHealthStatReceiver.java | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/9a6c7156/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java
index 3954610..a3e1fa0 100644
--- a/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java
+++ b/components/org.apache.stratos.autoscaler/src/main/java/org/apache/stratos/autoscaler/message/receiver/health/AutoscalerHealthStatReceiver.java
@@ -52,6 +52,10 @@ public class AutoscalerHealthStatReceiver implements Runnable {
private boolean terminated = false;
private HealthStatReceiver healthStatReceiver;
+
+ public AutoscalerHealthStatReceiver() {
+ this.healthStatReceiver = new HealthStatReceiver(createMessageDelegator());
+ }
// @Override
// public void run() {
// if(log.isInfoEnabled()) {
@@ -418,6 +422,8 @@ public class AutoscalerHealthStatReceiver implements Runnable {
//
+
+
@Override
public void run() {
//FIXME this activated before autoscaler deployer activated.
@@ -428,13 +434,13 @@ public class AutoscalerHealthStatReceiver implements Runnable {
Thread thread = new Thread(healthStatReceiver);
thread.start();
if(log.isInfoEnabled()) {
- log.info("Autoscaler topology receiver thread started");
+ log.info("Autoscaler heal stat receiver thread started");
}
// Keep the thread live until terminated
while (!terminated);
if(log.isInfoEnabled()) {
- log.info("Autoscaler topology receiver thread terminated");
+ log.info("Autoscaler health stat receiver thread terminated");
}
}