From d1d7c9d9dfb83d6d3ff9983c40a05a03164c07e6 Mon Sep 17 00:00:00 2001 From: "selva.andre" Date: Wed, 5 Sep 2012 19:37:51 +0200 Subject: [PATCH] Fixed log message --- .../main/java/org/dna/mqtt/moquette/server/MQTTHandler.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java b/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java index 05e4b0f5..76d3892a 100644 --- a/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java +++ b/parser/src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java @@ -4,6 +4,7 @@ import org.apache.mina.core.service.IoHandlerAdapter; import org.apache.mina.core.session.IdleStatus; import org.apache.mina.core.session.IoSession; import org.dna.mqtt.moquette.messaging.spi.IMessaging; +import org.dna.mqtt.moquette.proto.Utils; import org.dna.mqtt.moquette.proto.messages.AbstractMessage; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -23,7 +24,7 @@ public class MQTTHandler extends IoHandlerAdapter { @Override public void messageReceived(IoSession session, Object message) throws Exception { AbstractMessage msg = (AbstractMessage) message; - LOG.info("Received a message of type {0}", msg.getMessageType()); + LOG.info(String.format("Received a message of type %s", Utils.msgType2String(msg.getMessageType()))); try { switch (msg.getMessageType()) { case CONNECT: