diff options
| -rw-r--r-- | src/client.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/client.c b/src/client.c index e303fe9..b95c8d5 100644 --- a/src/client.c +++ b/src/client.c @@ -1121,7 +1121,10 @@ static int MqttClientHandlePublish(MqttClient *client) StreamReadMqttString(&topic, pss); - StreamReadUint16Be(&id, pss); + if (qos > 0) + { + StreamReadUint16Be(&id, pss); + } payload = bdataofs(ss.buffer, ss.pos); payloadSize = blength(ss.buffer) - ss.pos; |