diff options
| author | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-18 09:18:08 +0200 |
|---|---|---|
| committer | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-18 09:18:08 +0200 |
| commit | cec17d970b99058da216ec194d19c5421802b78e (patch) | |
| tree | afe8123cc297696b9e9fe224af606a6bcd813cf7 | |
| parent | 03f7cae60919a04ff0ebc87baf3b51b9bbb1776f (diff) | |
| download | mqtt-cec17d970b99058da216ec194d19c5421802b78e.tar.gz mqtt-cec17d970b99058da216ec194d19c5421802b78e.zip | |
Fix publish message serialization
All of the publish messages regardless of qos contained the message id.
| -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; |