Rebase the master and merge changes of PR 121
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/19a259c9 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/19a259c9 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/19a259c9 Branch: refs/heads/master Commit: 19a259c934cfbf530b38c19c7c1ef4bebe870d54 Parents: a00d961 Author: gayan <[email protected]> Authored: Fri Nov 28 17:15:46 2014 +0530 Committer: gayan <[email protected]> Committed: Fri Nov 28 18:27:34 2014 +0530 ---------------------------------------------------------------------- .../controller/internal/CloudControllerServiceComponent.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/19a259c9/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerServiceComponent.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerServiceComponent.java b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerServiceComponent.java index 4570eed..b07a875 100644 --- a/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerServiceComponent.java +++ b/components/org.apache.stratos.cloud.controller/src/main/java/org/apache/stratos/cloud/controller/internal/CloudControllerServiceComponent.java @@ -68,8 +68,8 @@ public class CloudControllerServiceComponent { protected void activate(ComponentContext context) { try { applicationTopicReceiver = new ApplicationTopicReceiver(); - ; - applicationTopicReceiver.run(); + Thread tApplicationTopicReceiver = new Thread(applicationTopicReceiver); + tApplicationTopicReceiver.start(); if (log.isInfoEnabled()) { log.info("Application Receiver thread started");
