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);