From 1ee08d484707f4e23802ea08df4f57199be3f4a6 Mon Sep 17 00:00:00 2001 From: andrea Date: Sun, 26 Aug 2012 13:16:01 +0200 Subject: [PATCH] Minor change added debug log --- .../src/main/java/org/dna/mqtt/moquette/server/MQTTHandler.java | 1 + 1 file changed, 1 insertion(+) 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 6bed0d07..c1736382 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 @@ -228,6 +228,7 @@ public class MQTTHandler extends IoHandlerAdapter implements INotifier { pubMessage.setPayload(payload); assert m_clientIDs != null; assert m_clientIDs.get(clientId) != null; + LOG.debug("Session for clientId " + clientId + " is " + m_clientIDs.get(clientId).getSession()); m_clientIDs.get(clientId).getSession().write(pubMessage); } }