MQTT Client: Added disconnect message on client stop

Closes #97 and closes espressif/esp-idf#3215
espressif · Mar 27, 2019 · caf5007 · caf5007
1 parent 57d2774
commit caf5007
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/mqtt_client.c b/mqtt_client.c
@@ -958,6 +958,14 @@ esp_err_t esp_mqtt_client_reconnect(esp_mqtt_client_handle_t client)
 esp_err_t esp_mqtt_client_stop(esp_mqtt_client_handle_t client)
 {
     if (client->run) {
+        // Notify the broker we are disconnecting
+        MQTT_API_LOCK_FROM_OTHER_TASK(client);
+        client->mqtt_state.outbound_message = mqtt_msg_disconnect(&client->mqtt_state.mqtt_connection);
+        if (mqtt_write_data(client) != ESP_OK) {
+            ESP_LOGE(TAG, "Error sending disconnect message");
+        }
+        MQTT_API_UNLOCK_FROM_OTHER_TASK(client);
+
         client->run = false;
         xEventGroupWaitBits(client->status_bits, STOPPED_BIT, false, true, portMAX_DELAY);
         client->state = MQTT_STATE_UNKNOWN;