Skip to content

Commit b437eb2

Browse files
committed
Enqueued qos0 dispatch MQTT_EVENT_PUBLISHED
1 parent 14f5fa0 commit b437eb2

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
@@ -1516,6 +1516,13 @@ static esp_err_t mqtt_resend_queued(esp_mqtt_client_handle_t client, outbox_item
15161516
if (outbox_delete_item(client->outbox, item) != ESP_OK) {
15171517
ESP_LOGE(TAG, "Failed to remove queued qos0 message from the outbox");
15181518
}
1519+
1520+
client->event.data_len = client->event.total_data_len = client->mqtt_state.connection.outbound_message.length;
1521+
client->event.current_data_offset = 0;
1522+
client->event.msg_id = client->mqtt_state.pending_msg_id;
1523+
client->event.qos = client->mqtt_state.pending_publish_qos;
1524+
client->event.event_id = MQTT_EVENT_PUBLISHED;
1525+
esp_mqtt_dispatch_event(client);
15191526
} else if (client->mqtt_state.pending_publish_qos > 0) {
15201527
#ifdef MQTT_PROTOCOL_5
15211528
if (client->mqtt_state.connection.information.protocol_ver == MQTT_PROTOCOL_V_5) {

0 commit comments

Comments
 (0)