anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request #301 from AndreasMager/missing-message-logging-added

Browse Source 
Missing message logging added
This commit is contained in:
Andrea Selva
2017-04-25 17:39:38 +02:00
committed by GitHub
parent 3a0eb3bea1 0247cfef9e
commit 67ab24570e
1 changed files with 14 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/server/netty/metrics/MQTTMessageLogger.java
+14 -11
View File
@@ -46,8 +46,10 @@ public class MQTTMessageLogger extends ChannelDuplexHandler {
MqttMessageType messageType = msg.fixedHeader().messageType();
switch (messageType) {
case CONNECT:
LOG.info("{} CONNECT client <{}>", direction, clientID);
case DISCONNECT:
LOG.info("{} {} <{}>", direction, messageType, clientID);
break;
case SUBSCRIBE:
MqttSubscribeMessage subscribe = (MqttSubscribeMessage) msg;
LOG.info("{} SUBSCRIBE <{}> to topics {}", direction, clientID,
@@ -61,21 +63,22 @@ public class MQTTMessageLogger extends ChannelDuplexHandler {
MqttPublishMessage publish = (MqttPublishMessage) msg;
LOG.info("{} PUBLISH <{}> to topics <{}>", direction, clientID, publish.variableHeader().topicName());
break;
case PUBREC:
LOG.info("{} PUBREC <{}> packetID <{}>", direction, clientID, messageId(msg));
break;
case PUBCOMP:
LOG.info("{} PUBCOMP <{}> packetID <{}>", direction, clientID, messageId(msg));
break;
case PUBREL:
LOG.info("{} PUBREL <{}> packetID <{}>", direction, clientID, messageId(msg));
break;
case DISCONNECT:
LOG.info("{} DISCONNECT <{}>", direction, clientID);
break;
case PUBACK:
LOG.info("{} PUBACK <{}> packetID <{}>", direction, clientID, messageId(msg));
LOG.info("{} {} <{}> packetID <{}>", direction, messageType, 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;