From 44a7c4d000376a1223eaee197c2cac18fcbab2c1 Mon Sep 17 00:00:00 2001 From: Andreas Mager Date: Tue, 25 Apr 2017 16:03:09 +0200 Subject: [PATCH] broker/MQTTMessageLogger: missing messages added --- .../moquette/server/netty/metrics/MQTTMessageLogger.java | 9 +++++++++ 1 file changed, 9 insertions(+) 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;