Skip to content

Commit 1cc5813

Browse files
committed
Enqueued qos0 dispatch MQTT_EVENT_PUBLISHED
1 parent cac1552 commit 1cc5813

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

mqtt_client.c

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1517,7 +1517,6 @@ static esp_err_t mqtt_resend_queued(esp_mqtt_client_handle_t client, outbox_item
15171517
esp_mqtt_abort_connection(client);
15181518
return ESP_FAIL;
15191519
}
1520-
15211520
return ESP_OK;
15221521
}
15231522

@@ -1670,6 +1669,13 @@ static void esp_mqtt_task(void *pv)
16701669
if (outbox_delete_item(client->outbox, item) != ESP_OK) {
16711670
ESP_LOGE(TAG, "Failed to remove queued qos0 message from the outbox");
16721671
}
1672+
1673+
client->event.data_len = client->event.total_data_len = client->mqtt_state.connection.outbound_message.length;
1674+
client->event.current_data_offset = 0;
1675+
client->event.msg_id = client->mqtt_state.pending_msg_id;
1676+
client->event.qos = client->mqtt_state.pending_publish_qos;
1677+
client->event.event_id = MQTT_EVENT_PUBLISHED;
1678+
esp_mqtt_dispatch_event(client);
16731679
}
16741680
if (client->mqtt_state.pending_publish_qos > 0) {
16751681
outbox_set_pending(client->outbox, client->mqtt_state.pending_msg_id, TRANSMITTED);

0 commit comments

Comments
 (0)