From 210b9ee1f224caa8605079acc239f607090810e7 Mon Sep 17 00:00:00 2001
From: Oskari Timperi <oskari.timperi@iki.fi>
Date: Fri, 17 Feb 2017 19:36:26 +0200
Subject: Include qos/retain in OnMessage callback

---
 src/client.c | 4 +++-
 src/mqtt.h   | 5 ++++-
 2 files changed, 7 insertions(+), 2 deletions(-)

(limited to 'src')

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);
 
-- 
cgit v1.2.3