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 9fc7a9e0..219c59dd 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 @@ -76,6 +76,15 @@ public class MQTTMessageLogger extends ChannelDuplexHandler { case PUBACK: LOG.info("{} PUBACK <{}> packetID <{}>", direction, clientID, messageId(msg)); break; + + case CONNACK: + case SUBACK: + case PINGREQ: + case PINGRESP: + case UNSUBACK: + LOG.debug("{} {} <{}> packetID <{}>", direction, messageType, clientID, messageId(msg)); + break; + default: LOG.error("Unkonwn MessageType:{}", messageType); break;