From e1d5a9402f08a21e3ca755afbbcd8d99be681902 Mon Sep 17 00:00:00 2001 From: Bert Melis Date: Mon, 20 Sep 2021 12:07:53 +0200 Subject: [PATCH] add qos and dup to MQTT_EVENT_DATA --- include/mqtt_client.h | 2 ++ mqtt_client.c | 2 ++ 2 files changed, 4 insertions(+) diff --git a/include/mqtt_client.h b/include/mqtt_client.h index 475581b..3595eb1 100644 --- a/include/mqtt_client.h +++ b/include/mqtt_client.h @@ -153,6 +153,8 @@ typedef struct { int session_present; /*!< MQTT session_present flag for connection event */ esp_mqtt_error_codes_t *error_handle; /*!< esp-mqtt error handle including esp-tls errors as well as internal mqtt errors */ bool retain; /*!< Retained flag of the message associated with this event */ + int qos; /*!< qos of the messages associated with this event */ + int dup; /*!< Dup flag of the message associated with this event */ } esp_mqtt_event_t; typedef esp_mqtt_event_t *esp_mqtt_event_handle_t; diff --git a/mqtt_client.c b/mqtt_client.c index d2c3d45..76a4c9a 100644 --- a/mqtt_client.c +++ b/mqtt_client.c @@ -981,6 +981,8 @@ static esp_err_t deliver_publish(esp_mqtt_client_handle_t client) // post data event client->event.retain = mqtt_get_retain(msg_buf); client->event.msg_id = mqtt_get_id(msg_buf, msg_data_len); + client->event.qos = mqtt_get_qos(msg_buf); + client->event.dup = mqtt_get_dup(msg_buff); client->event.total_data_len = msg_data_len + msg_total_len - msg_read_len; post_data_event: