From d8e432b4cf5e117db37d6f92286926d29c38327c Mon Sep 17 00:00:00 2001 From: Victor Kazakov Date: Mon, 24 Aug 2015 15:10:56 -0700 Subject: [PATCH] Fixing PubRelEncoder to encode PubRel message flag to match what is in the MQTT specification http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/os/mqtt-v3.1.1-os.html#_Toc398718054 --- .../java/org/eclipse/moquette/parser/netty/PubRelEncoder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PubRelEncoder.java b/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PubRelEncoder.java index 97a2c5e7..38adf48f 100644 --- a/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PubRelEncoder.java +++ b/netty_parser/src/main/java/org/eclipse/moquette/parser/netty/PubRelEncoder.java @@ -28,7 +28,7 @@ class PubRelEncoder extends DemuxEncoder { @Override protected void encode(ChannelHandlerContext chc, PubRelMessage msg, ByteBuf out) { - out.writeByte(AbstractMessage.PUBREL << 4); + out.writeByte(AbstractMessage.PUBREL << 4 | 0x02); out.writeBytes(Utils.encodeRemainingLength(2)); out.writeShort(msg.getMessageID()); }