diff options
| author | George Hazan <ghazan@miranda.im> | 2019-12-27 01:26:01 +0300 |
|---|---|---|
| committer | George Hazan <ghazan@miranda.im> | 2019-12-27 01:26:01 +0300 |
| commit | 225583a16f1a3b5ca5f4fccc6d8f3708c8c2d125 (patch) | |
| tree | bb986be46794ade820c1dde0511bf5a758f8eb85 /protocols/Facebook/src/mqtt.cpp | |
| parent | 2ca3d84092f9f004efc47c38a67ab34ceb008306 (diff) | |
Facebook: message queue initialization code
Diffstat (limited to 'protocols/Facebook/src/mqtt.cpp')
| -rw-r--r-- | protocols/Facebook/src/mqtt.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
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); } |