diff --git a/mqttpacket.cpp b/mqttpacket.cpp index d85b211..82b29b3 100644 --- a/mqttpacket.cpp +++ b/mqttpacket.cpp @@ -730,8 +730,7 @@ void MqttPacket::handleSubscribe() switch (prop) { case Mqtt5Properties::SubscriptionIdentifier: - decodeVariableByteIntAtPos(); - break; + throw ProtocolError("Subscription identifiers not supported", ReasonCodes::ProtocolError); case Mqtt5Properties::UserProperty: readUserProperty(); break;