From 1e4541c784701d2a21c93898e11a484800b55b88 Mon Sep 17 00:00:00 2001
From: "selva.andre" <andrea@sempai>
Date: Thu, 26 Jul 2012 23:53:11 +0200
Subject: [PATCH] Fixed bad encoding value of remaining length field

---
 .../java/org/dna/mqtt/moquette/proto/SubscribeEncoder.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/parser/src/main/java/org/dna/mqtt/moquette/proto/SubscribeEncoder.java b/parser/src/main/java/org/dna/mqtt/moquette/proto/SubscribeEncoder.java
index d5e5b0c9..b22b0ec8 100644
--- a/parser/src/main/java/org/dna/mqtt/moquette/proto/SubscribeEncoder.java
+++ b/parser/src/main/java/org/dna/mqtt/moquette/proto/SubscribeEncoder.java
@@ -34,10 +34,10 @@ public class SubscribeEncoder implements MessageEncoder<SubscribeMessage> {
         variableHeaderBuff.flip();
         int variableHeaderSize = variableHeaderBuff.remaining();
         byte flags = Utils.encodeFlags(message);
-        IoBuffer buff = IoBuffer.allocate(4 + variableHeaderSize);
+        IoBuffer buff = IoBuffer.allocate(2 + variableHeaderSize);
 
         buff.put((byte) (AbstractMessage.SUBSCRIBE << 4 | flags));
-        buff.put(Utils.encodeRemainingLength(4 + variableHeaderSize));
+        buff.put(Utils.encodeRemainingLength(variableHeaderSize));
         buff.put(variableHeaderBuff).flip();
 
         out.write(buff);