You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by la...@apache.org on 2013/11/26 07:36:41 UTC
git commit: Changing log level of health check logs
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 <la...@apache.org>
Authored: Tue Nov 26 12:11:21 2013 +0530
Committer: Lahiru Sandaruwan <la...@apache.org>
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) {