Updated Branches: refs/heads/master b431ec18b -> d7dadfcb5
Changing log level of health check logs Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/d7dadfcb Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/d7dadfcb Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/d7dadfcb Branch: refs/heads/master Commit: d7dadfcb5a8568d0c9d63db3cbfd39ce08373d58 Parents: b431ec1 Author: Lahiru Sandaruwan <[email protected]> Authored: Tue Nov 26 12:11:21 2013 +0530 Committer: Lahiru Sandaruwan <[email protected]> Committed: Tue Nov 26 12:11:21 2013 +0530 ---------------------------------------------------------------------- .../messaging/broker/heartbeat/TopicHealthChecker.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/d7dadfcb/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 bb8bc3c..a72445d 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 @@ -42,8 +42,9 @@ public class TopicHealthChecker implements Runnable { @Override public void run() { - log.info(topicName + " topic Health Checker is running... " ); - + if(log.isDebugEnabled()){ + log.debug(topicName + " topic Health Checker is running... " ); + } TopicConnector testConnector = new TopicConnector(); while (!terminated) { try { @@ -56,7 +57,7 @@ public class TopicHealthChecker implements Runnable { // implies connection is not established // sleep for 5s and retry try { - log.info(topicName + " topic Health Checker is failed and will retry to establish a connection after a 5s."); + log.error(topicName + " topic Health Checker is failed and will retry to establish a connection after a 5s."); Thread.sleep(5000); break; } catch (InterruptedException ignore) {
