diff --git a/mqtt_client.c b/mqtt_client.c index d4c074a..87177d6 100644 --- a/mqtt_client.c +++ b/mqtt_client.c @@ -1659,6 +1659,11 @@ static void esp_mqtt_task(void *pv) break; } + if (last_retransmit == 0) { + // connected for first time, set last_retransmit to now, avoid retransmit + last_retransmit = platform_tick_get_ms(); + } + // delete long pending messages mqtt_delete_expired_messages(client);