diff --git a/mqttpacket.cpp b/mqttpacket.cpp index 3659b90..34656ee 100644 --- a/mqttpacket.cpp +++ b/mqttpacket.cpp @@ -837,7 +837,11 @@ void MqttPacket::handlePublish() break; } case Mqtt5Properties::CorrelationData: + { + const uint16_t len = readTwoBytesToUInt16(); + readBytes(len); break; + } case Mqtt5Properties::UserProperty: { const uint16_t lenKey = readTwoBytesToUInt16(); @@ -848,7 +852,10 @@ void MqttPacket::handlePublish() break; } case Mqtt5Properties::SubscriptionIdentifier: + { + decodeVariableByteIntAtPos(); break; + } case Mqtt5Properties::ContentType: { const uint16_t len = readTwoBytesToUInt16();