Repository: stratos Updated Branches: refs/heads/master 976cf5630 -> 126d39695
addign executor service for health event receiver Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/126d3969 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/126d3969 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/126d3969 Branch: refs/heads/master Commit: 126d396955df2079453ba8b3ff539b029d753cfe Parents: 976cf56 Author: reka <[email protected]> Authored: Wed Dec 3 14:40:31 2014 +0530 Committer: reka <[email protected]> Committed: Wed Dec 3 14:40:31 2014 +0530 ---------------------------------------------------------------------- .../health/stat/HealthStatEventReceiver.java | 15 +++++---------- 1 file changed, 5 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/126d3969/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java index 0253704..07e7473 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/message/receiver/health/stat/HealthStatEventReceiver.java @@ -54,19 +54,14 @@ public class HealthStatEventReceiver { try { // Start topic subscriber thread subscriber = new Subscriber(Util.Topics.HEALTH_STAT_TOPIC.getTopicName(), messageListener); -// subscriber.setMessageListener(messageListener); - Thread subscriberThread = new Thread(subscriber); - subscriberThread.start(); - if (log.isDebugEnabled()) { - log.debug("Health stats event message receiver thread started"); - } - // Start health stat event message delegator thread - Thread receiverThread = new Thread(messageDelegator); - receiverThread.start(); - if (log.isDebugEnabled()) { + executorService.execute(subscriber); + + if (log.isDebugEnabled()) { log.debug("Health stats event message delegator thread started"); } + // Start topology event message delegator thread + executorService.execute(messageDelegator); } catch (Exception e) { if (log.isErrorEnabled()) { log.error("Topology receiver failed", e);
