diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/client.c | 4 | ||||
| -rw-r--r-- | src/mqtt.h | 5 |
2 files changed, 7 insertions, 2 deletions
diff --git a/src/client.c b/src/client.c index 6839867..34062ed 100644 --- a/src/client.c +++ b/src/client.c @@ -694,7 +694,9 @@ static void MqttClientHandlePublish(MqttClient *client, MqttPacketPublish *packe client->onMessage(client, bdata(packet->topicName), bdata(packet->message), - blength(packet->message)); + blength(packet->message), + packet->qos, + packet->retain); } if (MqttPacketPublishQos(packet) > 0) @@ -39,7 +39,10 @@ typedef void (*MqttClientOnUnsubscribeCallback)(MqttClient *client, int id); typedef void (*MqttClientOnMessageCallback)(MqttClient *client, const char *topic, - const void *data, size_t size); + const void *data, + size_t size, + int qos, + int retain); typedef void (*MqttClientOnPublishCallback)(MqttClient *client, int id); |