Repository: stratos Updated Branches: refs/heads/docker-grouping-merge 5dd5c296d -> 289d96235
Changing topic subscription info log to debug Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/40a34f12 Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/40a34f12 Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/40a34f12 Branch: refs/heads/docker-grouping-merge Commit: 40a34f1215f5137fc3a04cf48e37fee9ba273f05 Parents: bd9cc1c Author: Imesh Gunaratne <[email protected]> Authored: Fri Nov 7 23:13:38 2014 +0530 Committer: Imesh Gunaratne <[email protected]> Committed: Fri Nov 7 23:13:38 2014 +0530 ---------------------------------------------------------------------- .../stratos/messaging/broker/subscribe/TopicSubscriber.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/40a34f12/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java ---------------------------------------------------------------------- diff --git a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java index ec1d238..f66ef98 100644 --- a/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java +++ b/components/org.apache.stratos.messaging/src/main/java/org/apache/stratos/messaging/broker/subscribe/TopicSubscriber.java @@ -66,8 +66,8 @@ public class TopicSubscriber implements Runnable { private void doSubscribe() throws MqttException { - if (log.isInfoEnabled()) { - log.info(String.format("Subscribing to topic: [topic] %s [server] %s", + if (log.isDebugEnabled()) { + log.debug(String.format("Subscribing to topic: [topic] %s [server] %s", topicName, mqttClient.getServerURI())); }
