diff --git a/mqtt_client.c b/mqtt_client.c index 5518cf1..e189161 100644 --- a/mqtt_client.c +++ b/mqtt_client.c @@ -1653,6 +1653,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); }