From 0f3b3f9ee62204213f57772cd518b33b9caeffe6 Mon Sep 17 00:00:00 2001
From: Ricardo JL Rufino <ricardo.jl.rufino@gmail.com>
Date: Thu, 9 Aug 2018 23:42:01 -0300
Subject: [PATCH] Update MQTTMessageLogger.java

reduce the level of logging to less significant things
---
 .../io/moquette/server/netty/metrics/MQTTMessageLogger.java | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java b/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java
index 85519d08..f5777dcc 100644
--- a/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java
+++ b/broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java
@@ -57,10 +57,12 @@ public class MQTTMessageLogger extends ChannelDuplexHandler {
         String clientID = NettyUtils.clientID(ctx.channel());
         MqttMessageType messageType = msg.fixedHeader().messageType();
         switch (messageType) {
-            case CONNECT:
             case CONNACK:
             case PINGREQ:
             case PINGRESP:
+                LOG.debug("{} {} <{}>", direction, messageType, clientID);
+                break;        
+            case CONNECT:
             case DISCONNECT:
                 LOG.info("{} {} <{}>", direction, messageType, clientID);
                 break;
@@ -75,7 +77,7 @@ public class MQTTMessageLogger extends ChannelDuplexHandler {
                 break;
             case PUBLISH:
                 MqttPublishMessage publish = (MqttPublishMessage) msg;
-                LOG.info("{} PUBLISH <{}> to topics <{}>", direction, clientID, publish.variableHeader().topicName());
+                LOG.debug("{} PUBLISH <{}> to topics <{}>", direction, clientID, publish.variableHeader().topicName());
                 break;
             case PUBREC:
             case PUBCOMP: