diff --git a/mqtt_client.c b/mqtt_client.c index ccc38b9..98c27b2 100644 --- a/mqtt_client.c +++ b/mqtt_client.c @@ -1571,6 +1571,7 @@ static void esp_mqtt_task(void *pv) esp_transport_close(client->transport); outbox_delete_all_items(client->outbox); xEventGroupSetBits(client->status_bits, STOPPED_BIT); + client->state = MQTT_STATE_DISCONNECTED; vTaskDelete(NULL); }