MQTT event issue

[Ssg ssg]

Hello Fellows, I searching for someone expert in mqtt for help-me.
I'm using basically the mqtt/ssl example from espressif github and I cannot publish nothing!
The secure tcp link as well wifi initialization with my certification is ok (if I change any character in certificate I get initialization error...)
When the mqtt is started and connected I get "hello" from the example message then I set one flag to start my publish just after when connected with broker and I send the same message but I get error "E (9500) mqtt_client: Client was not initialized" and the data does not go ahead...
Below my code as well the error message after my publish.
Whats is wrong? I could not get any information about that for esp-idf V5.3 version...

Code: [Select all] [Expand/Collapse]

1. #include <esp_err.h>
2.  
3. #include "mqtt_handler.h"
4.  
5. #include <stdio.h>
6. #include <stdint.h>
7. #include <stddef.h>
8. #include <string.h>
9. #include "esp_system.h"
10. #include "esp_partition.h"
11. #include "nvs_flash.h"
12. #include "esp_event.h"
13. #include "esp_netif.h"
14. #include "protocol_examples_common.h"
15. #include "esp_log.h"
16. #include "mqtt_client.h"
17. #include "esp_tls.h"
18. #include "esp_ota_ops.h"
19. #include <sys/param.h>
20.  
21. #define EXAMPLE_ESP_WIFI_STA_SSID "xxxx"
22. #define EXAMPLE_ESP_WIFI_STA_PASSWD "yyyyy"
23.  
24. extern bool flagMqtt;
25.  
26. static const char *TAG = "MQTTS";
27. static void send_binary(esp_mqtt_client_handle_t client)
28. {
29.     esp_partition_mmap_handle_t out_handle;
30.     const void *binary_address;
31.     const esp_partition_t *partition = esp_ota_get_running_partition();
32.     esp_partition_mmap(partition, 0, partition->size, ESP_PARTITION_MMAP_DATA, &binary_address, &out_handle);
33.     // sending only the configured portion of the partition (if it's less than the partition size)
34.     int binary_size = MIN(CONFIG_BROKER_BIN_SIZE_TO_SEND, partition->size);
35.     int msg_id = esp_mqtt_client_publish(client, "/topic/binary", binary_address, binary_size, 0, 0);
36.     ESP_LOGI(TAG, "binary sent with msg_id=%d", msg_id);
37. }
38.  
39. /*
40.  * @brief Event handler registered to receive MQTT events
41.  *
42.  *  This function is called by the MQTT client event loop.
43.  *
44.  * @param handler_args user data registered to the event.
45.  * @param base Event base for the handler(always MQTT Base in this example).
46.  * @param event_id The id for the received event.
47.  * @param event_data The data for the event, esp_mqtt_event_handle_t.
48.  */
49. static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data)
50. {
51.     ESP_LOGD(TAG, "Event dispatched from event loop base=%s, event_id=%" PRIi32, base, event_id);
52.     esp_mqtt_event_handle_t event = event_data;
53.     esp_mqtt_client_handle_t client = event->client;
54.     int msg_id=0;
55.     switch ((esp_mqtt_event_id_t)event_id) {
56.         case MQTT_EVENT_BEFORE_CONNECT:
57.             ESP_LOGI(TAG, "MQTT_EVENT_BEFORE_CONNECT");
58.             break;
59.         case MQTT_EVENT_CONNECTED:
60.             flagMqtt=1;     // indica que conectou
61.             ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED");
62.             msg_id = esp_mqtt_client_subscribe(client, "/topic/1", 0);
63.             ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id);
64.             break;
65.         case MQTT_EVENT_DISCONNECTED:
66.             ESP_LOGI(TAG, "MQTT_EVENT_DISCONNECTED");
67.             break;
68.         case MQTT_EVENT_SUBSCRIBED:
69.             ESP_LOGI(TAG, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id);
70.             msg_id = esp_mqtt_client_publish(client, "/topic/1", "hello", 0, 0, 0);
71.             ESP_LOGI(TAG, "sent publish successful, msg_id=%d", msg_id);
72.             break;
73.         case MQTT_EVENT_UNSUBSCRIBED:
74.             ESP_LOGI(TAG, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id);
75.             break;
76.         case MQTT_EVENT_PUBLISHED:
77.             ESP_LOGI(TAG, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id);
78.             break;
79.         case MQTT_EVENT_DATA:
80.             ESP_LOGI(TAG, "MQTT_EVENT_DATA");
81.             printf("TOPIC=%.*s\n", event->topic_len, event->topic);
82.             printf("DATA=%.*s\n", event->data_len, event->data);
83.             if (strncmp(event->data, "send binary please", event->data_len) == 0) {
84.                 ESP_LOGI(TAG, "Sending the binary");
85.                 send_binary(client);
86.             }
87.             break;
88.         case MQTT_EVENT_ERROR:
89.             ESP_LOGI(TAG, "MQTT_EVENT_ERROR");
90.             if (event->error_handle->error_type == MQTT_ERROR_TYPE_TCP_TRANSPORT) {
91.                 ESP_LOGI(TAG, "Last error code reported from esp-tls: 0x%x", event->error_handle->esp_tls_last_esp_err);
92.                 ESP_LOGI(TAG, "Last tls stack error number: 0x%x", event->error_handle->esp_tls_stack_err);
93.                 ESP_LOGI(TAG, "Last captured errno : %d (%s)",  event->error_handle->esp_transport_sock_errno,
94.                         strerror(event->error_handle->esp_transport_sock_errno));
95.             } else if (event->error_handle->error_type == MQTT_ERROR_TYPE_CONNECTION_REFUSED) {
96.                 ESP_LOGI(TAG, "Connection refused error: 0x%x", event->error_handle->connect_return_code);
97.             } else {
98.                 ESP_LOGW(TAG, "Unknown error type: 0x%x", event->error_handle->error_type);
99.             }
100.             break;
101.         default:
102.             ESP_LOGI(TAG, "Other event id:%d", event->event_id);
103.             break;
104.     }
105. }
106.  
107. static void mqtt_app_start(void)
108. {
109.     const esp_mqtt_client_config_t mqtt_cfg = {
110.         .broker = {
111.             .address.uri = CONFIG_BROKER_URI,
112.             .verification.certificate = (const char *)my_certificate
113.         },
114.     };
115.  
116.     ESP_LOGI(TAG, "[APP] Free memory: %" PRIu32 " bytes", esp_get_free_heap_size());
117.     esp_mqtt_client_handle_t client = esp_mqtt_client_init(&mqtt_cfg);
118.     /* The last argument may be used to pass data to the event handler, in this example mqtt_event_handler */
119.     esp_mqtt_client_register_event(client, ESP_EVENT_ANY_ID, mqtt_event_handler, NULL);
120.     esp_mqtt_client_start(client);
121.     ESP_LOGI(TAG, "Client started!");
122. }
123.  
124.  
125. esp_err_t esp32_mqtt_initialize(void){
126.     ESP_LOGI(TAG, "[APP] Startup..");
127.  
128.     esp_log_level_set("*", ESP_LOG_INFO);
129.     esp_log_level_set("esp-tls", ESP_LOG_VERBOSE);
130.     esp_log_level_set("mqtt_client", ESP_LOG_VERBOSE);
131.     esp_log_level_set("mqtt_example", ESP_LOG_VERBOSE);
132.     esp_log_level_set("transport_base", ESP_LOG_VERBOSE);
133.     esp_log_level_set("transport", ESP_LOG_VERBOSE);
134.     esp_log_level_set("outbox", ESP_LOG_VERBOSE);
135.     ESP_ERROR_CHECK(nvs_flash_init());
136.     ESP_ERROR_CHECK(esp_netif_init());
137.     ESP_ERROR_CHECK(esp_event_loop_create_default());
138.  
139.     /* This helper function configures Wi-Fi or Ethernet, as selected in menuconfig.
140.      * Read "Establishing Wi-Fi or Ethernet Connection" section in
141.      * examples/protocols/README.md for more information about this function.
142.      */
143.     ESP_ERROR_CHECK(example_connect());
144.     mqtt_app_start();
145.     return ESP_OK;
146. }
147.  
148. void publish(void){
149. static esp_mqtt_client_handle_t client;
150.     vTaskDelay(200);
151.     int msg_id=1;
152.  
153.     if(flagMqtt){
154.         flagMqtt=0;
155.            msg_id = esp_mqtt_client_publish(client, "/topic/1", "hello", 0, 0, 0);
156.     }
157. }

GeSHi © Codebox Plus Extension

I (6690) main: Initializing WDT...
I (6690) wdt_handler: Watchdog initialized with the following parameters:
timeout time in millisseconds: 2900
I (6990) main_task: Returned from app_main()
I (7130) MQTTS: MQTT_EVENT_CONNECTED
I (7150) MQTTS: MQTT_EVENT_SUBSCRIBED, msg_id=10608
I (7150) MQTTS: sent publish successful, msg_id=0
I (7210) MQTTS: MQTT_EVENT_DATA
TOPIC=/topic/1
DATA=hello
W (7770) wifi:<ba-add>idx:2, ifx:0, tid:6, TAHI:0x10092bc, TALO:0x30f91684, (ssn:2, win:64, cur_ssn:2), CONF:0xc0006005
E (9500) mqtt_client: Client was not initialized

[chegewara]

Try to pass client by reference

Code: Select all

static void send_binary(esp_mqtt_client_handle_t &client)

or even better make this handle global and use it

Code: Select all

static esp_mqtt_client_handle_t client; <--- make this global
...
client = esp_mqtt_client_init(&mqtt_cfg);
...

[Ssg ssg]

Hi Chegevara,
Doing handle global it works, great!
Thanks