From 5e397ea6d99b68916324c05ac6abb084bc97ba87 Mon Sep 17 00:00:00 2001
From: andsel <selva.andre@gmail.com>
Date: Wed, 23 Sep 2015 17:05:48 +0200
Subject: [PATCH] Minor change, just changed log level in PublishDecoder

---
 .../org/eclipse/moquette/parser/netty/PublishDecoder.java    | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PublishDecoder.java b/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PublishDecoder.java
index 7586b703..c991d038 100644
--- a/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PublishDecoder.java
+++ b/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PublishDecoder.java
@@ -35,14 +35,14 @@ class PublishDecoder extends DemuxDecoder {
 
     @Override
     void decode(AttributeMap ctx, ByteBuf in, List<Object> out) throws Exception {
-        LOG.info("decode invoked with buffer {}", in);
+        LOG.debug("decode invoked with buffer {}", in);
         in.resetReaderIndex();
         int startPos = in.readerIndex();
 
         //Common decoding part
         PublishMessage message = new PublishMessage();
         if (!decodeCommonHeader(message, in)) {
-            LOG.info("decode ask for more data after {}", in);
+            LOG.debug("decode ask for more data after {}", in);
             in.resetReaderIndex();
             return;
         }
@@ -89,7 +89,6 @@ class PublishDecoder extends DemuxDecoder {
             in.resetReaderIndex();
             return;
         }
-//        byte[] b = new byte[payloadSize];
         ByteBuf bb = Unpooled.buffer(payloadSize);
         in.readBytes(bb);
         message.setPayload(bb.nioBuffer());