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 <[email protected]> Authored: Fri Oct 31 20:17:10 2014 +0530 Committer: Imesh Gunaratne <[email protected]> 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);
