From 225583a16f1a3b5ca5f4fccc6d8f3708c8c2d125 Mon Sep 17 00:00:00 2001 From: George Hazan Date: Fri, 27 Dec 2019 01:26:01 +0300 Subject: Facebook: message queue initialization code --- protocols/Facebook/src/mqtt.cpp | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) (limited to 'protocols/Facebook/src/mqtt.cpp') diff --git a/protocols/Facebook/src/mqtt.cpp b/protocols/Facebook/src/mqtt.cpp index f23ee010c8..7c76953836 100644 --- a/protocols/Facebook/src/mqtt.cpp +++ b/protocols/Facebook/src/mqtt.cpp @@ -110,9 +110,10 @@ bool FacebookProto::MqttParse(const MqttMessage &payload) case FB_MQTT_MESSAGE_TYPE_PUBREL: mid = ntohs(*(u_short *)pData); + pData += 2; { MqttMessage reply(FB_MQTT_MESSAGE_TYPE_PUBCOMP); - reply << mid; + reply.writeInt16(mid); MqttSend(reply); } break; @@ -122,9 +123,10 @@ bool FacebookProto::MqttParse(const MqttMessage &payload) if ((flags & FB_MQTT_MESSAGE_FLAG_QOS1) || (flags & FB_MQTT_MESSAGE_FLAG_QOS2)) { mid = ntohs(*(u_short *)pData); + pData += 2; MqttMessage reply((flags & FB_MQTT_MESSAGE_FLAG_QOS1) ? FB_MQTT_MESSAGE_TYPE_PUBACK : FB_MQTT_MESSAGE_TYPE_PUBREC); - reply << mid; + reply.writeInt16(mid); MqttSend(reply); } -- cgit v1.2.3