mqtt with single use credentials

[Kakomis]

Hi Mair,
I'm using single use mqtt credentials so I have to handle reconnection by my own, I have this:

static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data)
{
  esp_mqtt_event_handle_t event = event_data;

  switch ((esp_mqtt_event_id_t)event_id)
  {
  case MQTT_EVENT_CONNECTED:
    ESP_LOGI(TAGO, "MQTT_EVENT_CONNECTED");
    xTaskNotify(taskHandle, MQTT_CONNECTED, eSetValueWithOverwrite);
    break;
  case MQTT_EVENT_DISCONNECTED:
    ESP_LOGI(TAGO, "MQTT_EVENT_DISCONNECTED, msg_id=%d", event->msg_id);
    xTaskNotify(taskHandle, WIFI_CONNECTED, eSetValueWithOverwrite);
    break;
  case MQTT_EVENT_SUBSCRIBED:
    ESP_LOGI(TAGO, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id);
    xTaskNotify(taskHandle, MQTT_SUBSCRIBED, eSetValueWithOverwrite);
    break;
  case MQTT_EVENT_UNSUBSCRIBED:
    ESP_LOGI(TAGO, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id);
    break;
  case MQTT_EVENT_PUBLISHED:
    ESP_LOGI(TAGO, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id);
    break;
  case MQTT_EVENT_DATA:
    ESP_LOGI(TAGO, "MQTT_EVENT_DATA");
    process_incoming_msg(event->topic, event->topic_len, event->data, event->data_len);
    break;
  case MQTT_EVENT_ERROR:
    ESP_LOGI(TAGO, "MQTT_EVENT_ERROR");
    break;
  default:
    ESP_LOGI(TAGO, "Other event id: %d", event->event_id);
    break;
  }
}

void onConnected(void *params)
{
  uint32_t command = 0;
  esp_mqtt_client_handle_t client = NULL;

  while (true)
  {
    xTaskNotifyWait(0, 0, &command, portMAX_DELAY);
    switch (command)
    {
    case WIFI_CONNECTED:
      ESP_LOGI(TAGO, "WIFI_CONNECTED");
      get_mqtt_credentials(); // <-- here GOT_CREDENTIALS is called.
      break;
    case GOT_CREDENTIALS:
    {
      esp_mqtt_client_config_t mqttConfig = {
          .uri = "mqtts://my.mqtt.server:8883",
          .cert_pem = (char *)cert,
          .client_id = get_randomId(),
          .username = mqtt_data.user,
          .password = mqtt_data.pass,
          .keepalive = (int)60,
      };

      ESP_LOGI(TAGO, "[APP] 1 Free memory: %d bytes", esp_get_free_heap_size());

      if (client != NULL)
      {
        toggle_led(false);
        esp_mqtt_client_destroy(client);
      }

      ESP_LOGI(TAGO, "[APP] 2 Free memory: %d bytes", esp_get_free_heap_size());

      client = esp_mqtt_client_init(&mqttConfig);
      esp_mqtt_client_register_event(client, ESP_EVENT_ANY_ID, mqtt_event_handler, client);
      esp_mqtt_client_start(client);
    }
    break;
    case MQTT_CONNECTED:
    {
      toggle_led(true);
      char topic[64] = "";
      strcat(topic, mqtt_data.topic);
      strcat(topic, "+/actdata");
      esp_mqtt_client_subscribe(client, topic, 1);
    }
    break;
    case MQTT_SUBSCRIBED:
    {
      publish_data_t publish_data;
      if (xQueueReceive(queue, &publish_data, portMAX_DELAY))
      {
        esp_mqtt_client_publish(client, publish_data.topic, publish_data.payload, strlen(publish_data.payload), 1, false);
      }
    }
    break;
    default:
      break;
    }
  }
}

The thing is when MQTT_EVENT_DISCONNECTED occurs xTaskNotifyWait(0, 0, &command, portMAX_DELAY); is never called, I only get this message:

E (31986) MQTT_CLIENT: mqtt_message_receive: transport_read() error: errno=119
I (31986) MQTT: MQTT_EVENT_ERROR
E (31986) MQTT_CLIENT: mqtt_process_receive: mqtt_message_receive() returned -1
I (31996) MQTT: MQTT_EVENT_DISCONNECTED, msg_id=44288
I (42006) MQTT: Other event id: 7
W (43136) MQTT_CLIENT: Connection refused, not authorized
I (43136) MQTT: MQTT_EVENT_ERROR
E (43136) MQTT_CLIENT: MQTT connect failed
I (43146) MQTT: MQTT_EVENT_DISCONNECTED, msg_id=0
I (58146) MQTT: Other event id: 7
W (59216) MQTT_CLIENT: Connection refused, not authorized
I (59216) MQTT: MQTT_EVENT_ERROR
E (59216) MQTT_CLIENT: MQTT connect failed
I (59226) MQTT: MQTT_EVENT_DISCONNECTED, msg_id=0
I (74226) MQTT: Other event id: 7
W (75286) MQTT_CLIENT: Connection refused, not authorized
I (75296) MQTT: MQTT_EVENT_ERROR
E (75296) MQTT_CLIENT: MQTT connect failed
I (75296) MQTT: MQTT_EVENT_DISCONNECTED, msg_id=0
I (90296) MQTT: Other event id: 7
W (91366) MQTT_CLIENT: Connection refused, not authorized
I (91366) MQTT: MQTT_EVENT_ERROR
E (91366) MQTT_CLIENT: MQTT connect failed
I (91376) MQTT: MQTT_EVENT_DISCONNECTED, msg_id=0

It would be great if you could help me.

[noweare1]

You could try esp_mqtt_client_stop() command if mqtt disconnected. Then try to reconnect as in the code. There is also a reconnect command esp_mqtt_client_reconnect() to see if you can reconnect without going through the whole config process again.