Skip to content

Commit ec7b69e

Browse files
committed
Enqueued qos0 dispatch MQTT_EVENT_PUBLISHED
1 parent bed1207 commit ec7b69e

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

mqtt_client.c

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1520,6 +1520,13 @@ static esp_err_t mqtt_resend_queued(esp_mqtt_client_handle_t client, outbox_item
15201520
if (outbox_delete_item(client->outbox, item) != ESP_OK) {
15211521
ESP_LOGE(TAG, "Failed to remove queued qos0 message from the outbox");
15221522
}
1523+
1524+
client->event.data_len = client->event.total_data_len = client->mqtt_state.connection.outbound_message.length;
1525+
client->event.current_data_offset = 0;
1526+
client->event.msg_id = client->mqtt_state.pending_msg_id;
1527+
client->event.qos = client->mqtt_state.pending_publish_qos;
1528+
client->event.event_id = MQTT_EVENT_PUBLISHED;
1529+
esp_mqtt_dispatch_event(client);
15231530
} else if (client->mqtt_state.pending_publish_qos > 0) {
15241531
#ifdef MQTT_PROTOCOL_5
15251532
if (client->mqtt_state.connection.information.protocol_ver == MQTT_PROTOCOL_V_5) {

0 commit comments

Comments
 (0)