You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by re...@apache.org on 2014/12/03 10:10:52 UTC
stratos git commit: addign executor service for health event receiver
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 <rt...@gmail.com>
Authored: Wed Dec 3 14:40:31 2014 +0530
Committer: reka <rt...@gmail.com>
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);