Include qos/retain in OnMessage callback

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)
diff --git a/src/mqtt.h b/src/mqtt.h
index 6c16ea6..74b1ac0 100644
--- a/src/mqtt.h
+++ b/src/mqtt.h
@@ -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);