diff options
| -rw-r--r-- | src/client.c | 4 | ||||
| -rw-r--r-- | src/mqtt.h | 5 | ||||
| -rw-r--r-- | tools/sub.c | 2 |
3 files changed, 8 insertions, 3 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); diff --git a/tools/sub.c b/tools/sub.c index 4937584..ffaf2a2 100644 --- a/tools/sub.c +++ b/tools/sub.c @@ -28,7 +28,7 @@ void onSubscribe(MqttClient *client, int id, MqttSubscriptionStatus status) } void onMessage(MqttClient *client, const char *topic, const void *data, - size_t size) + size_t size, int qos, int retain) { (void) client; printf("onMessage topic=<%s> message=<%.*s>\n", topic, (int) size, |