From faa7ae28860fbd63c9b8bb319180062021f6b521 Mon Sep 17 00:00:00 2001 From: Feng Lee Date: Wed, 1 Jun 2016 11:52:21 +0800 Subject: [PATCH] Fix issue#575 --- src/emqttd_parser.erl | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/emqttd_parser.erl b/src/emqttd_parser.erl index a561b5c99..7ad1a0f50 100644 --- a/src/emqttd_parser.erl +++ b/src/emqttd_parser.erl @@ -136,14 +136,14 @@ parse_frame(Bin, #mqtt_packet_header{type = Type, qos = Qos} = Header, Length) <> = FrameBin, wrap(Header, #mqtt_packet_puback{packet_id = PacketId}, Rest); {?PUBREL, <>} -> - 1 = Qos, + %% 1 = Qos, <> = FrameBin, wrap(Header, #mqtt_packet_puback{packet_id = PacketId}, Rest); {?PUBCOMP, <>} -> <> = FrameBin, wrap(Header, #mqtt_packet_puback{packet_id = PacketId}, Rest); {?SUBSCRIBE, <>} -> - 1 = Qos, + %% 1 = Qos, <> = FrameBin, TopicTable = parse_topics(?SUBSCRIBE, Rest1, []), wrap(Header, #mqtt_packet_subscribe{packet_id = PacketId, @@ -153,7 +153,7 @@ parse_frame(Bin, #mqtt_packet_header{type = Type, qos = Qos} = Header, Length) % wrap(Header, #mqtt_packet_suback{packet_id = PacketId, % qos_table = parse_qos(Rest1, []) }, Rest); {?UNSUBSCRIBE, <>} -> - 1 = Qos, + %% 1 = Qos, <> = FrameBin, Topics = parse_topics(?UNSUBSCRIBE, Rest1, []), wrap(Header, #mqtt_packet_unsubscribe{packet_id = PacketId,