Updated Branches: refs/heads/master 24a47afe1 -> 330ca5ecf
fixing STRATOS-205 Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/71a6b144 Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/71a6b144 Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/71a6b144 Branch: refs/heads/master Commit: 71a6b144264ab105f73fa0489b6d16b065b35473 Parents: 8e05df9 Author: Lahiru Sandaruwan <[email protected]> Authored: Tue Nov 26 11:14:04 2013 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Tue Nov 26 11:14:04 2013 +0530 ---------------------------------------------------------------------- .../stratos/messaging/broker/heartbeat/TopicHealthChecker.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/71a6b144/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/heartbeat/TopicHealthChecker.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/heartbeat/TopicHealthChecker.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/heartbeat/TopicHealthChecker.java index 0327c20..d2b6e4d 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/heartbeat/TopicHealthChecker.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/heartbeat/TopicHealthChecker.java @@ -18,12 +18,12 @@ */ package org.apache.stratos.messaging.broker.heartbeat; -import javax.jms.JMSException; - import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; import org.apache.stratos.messaging.broker.connect.TopicConnector; +import javax.jms.JMSException; + /** * This health checker runs forever, and is responsible for checking the * connection @@ -42,7 +42,7 @@ public class TopicHealthChecker implements Runnable { @Override public void run() { - log.info("Topic Health Checker is running... "); + log.info(topicName + " topic Health Checker is running... " ); TopicConnector testConnector = new TopicConnector(); while (!terminated) {
