We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 60c76d5 + 32dada4 commit a0f4ce8Copy full SHA for a0f4ce8
mqtt_client.c
@@ -1574,6 +1574,8 @@ static void esp_mqtt_task(void *pv)
1574
while (client->run) {
1575
MQTT_API_LOCK(client);
1576
run_event_loop(client);
1577
+ // delete long pending messages
1578
+ mqtt_delete_expired_messages(client);
1579
mqtt_client_state_t state = client->state;
1580
switch (state) {
1581
case MQTT_STATE_DISCONNECTED:
@@ -1653,8 +1655,6 @@ static void esp_mqtt_task(void *pv)
1653
1655
last_retransmit = platform_tick_get_ms();
1654
1656
}
1657
- // delete long pending messages
- mqtt_delete_expired_messages(client);
1658
1659
// resend all non-transmitted messages first
1660
outbox_item_handle_t item = outbox_dequeue(client->outbox, QUEUED, NULL);
0 commit comments