You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by im...@apache.org on 2014/10/31 15:47:18 UTC
git commit: Adding missing application status message receiver in
cloud controller
Repository: stratos
Updated Branches:
refs/heads/docker-grouping-merge fe674def5 -> 47b31d086
Adding missing application status message receiver in cloud controller
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/47b31d08
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/47b31d08
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/47b31d08
Branch: refs/heads/docker-grouping-merge
Commit: 47b31d08608c9f0dcf7c2c3f4485629746769b04
Parents: fe674de
Author: Imesh Gunaratne <im...@apache.org>
Authored: Fri Oct 31 20:17:10 2014 +0530
Committer: Imesh Gunaratne <im...@apache.org>
Committed: Fri Oct 31 20:17:10 2014 +0530
----------------------------------------------------------------------
.../controller/internal/CloudControllerDSComponent.java | 12 +++++++++++-
1 file changed, 11 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/47b31d08/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerDSComponent.java
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerDSComponent.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerDSComponent.java
index 797f299..604aed8 100644
--- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerDSComponent.java
+++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerDSComponent.java
@@ -79,7 +79,17 @@ public class CloudControllerDSComponent {
InstanceStatusEventMessageDelegator delegator = new InstanceStatusEventMessageDelegator();
Thread tdelegator = new Thread(delegator);
tdelegator.start();
-
+ if(log.isInfoEnabled()) {
+ log.info("Instance status message receiver thread started");
+ }
+
+ ApplicationStatusTopicReceiver applicationStatusTopicReceiver = new ApplicationStatusTopicReceiver();
+ Thread appThread = new Thread(applicationStatusTopicReceiver);
+ appThread.start();
+ if(log.isInfoEnabled()) {
+ log.info("Application status message receiver thread started");
+ }
+
// Register cloud controller service
BundleContext bundleContext = context.getBundleContext();
bundleContext.registerService(CloudControllerService.class.getName(), new CloudControllerServiceImpl(), null);