|
|
@@ -0,0 +1,101 @@
|
|
|
+/* Build only example to check mqtt client API from C++
|
|
|
+
|
|
|
+ This example code is in the Public Domain (or CC0 licensed, at your option.)
|
|
|
+
|
|
|
+ Unless required by applicable law or agreed to in writing, this
|
|
|
+ software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
|
|
|
+ CONDITIONS OF ANY KIND, either express or implied.
|
|
|
+*/
|
|
|
+
|
|
|
+#include <stdint.h>
|
|
|
+#include "esp_system.h"
|
|
|
+#include "nvs_flash.h"
|
|
|
+#include "esp_event.h"
|
|
|
+#include "esp_netif.h"
|
|
|
+#include "esp_log.h"
|
|
|
+#include "mqtt_client.h"
|
|
|
+
|
|
|
+static const char *TAG = "MQTT_EXAMPLE";
|
|
|
+
|
|
|
+
|
|
|
+static esp_err_t mqtt_event_handler_cb(esp_mqtt_event_handle_t event)
|
|
|
+{
|
|
|
+ switch (event->event_id) {
|
|
|
+ case MQTT_EVENT_CONNECTED:
|
|
|
+ ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED");
|
|
|
+ break;
|
|
|
+ case MQTT_EVENT_DISCONNECTED:
|
|
|
+ ESP_LOGI(TAG, "MQTT_EVENT_DISCONNECTED");
|
|
|
+ break;
|
|
|
+
|
|
|
+ case MQTT_EVENT_SUBSCRIBED:
|
|
|
+ ESP_LOGI(TAG, "MQTT_EVENT_SUBSCRIBED, msg_id=%d", event->msg_id);
|
|
|
+ break;
|
|
|
+ case MQTT_EVENT_UNSUBSCRIBED:
|
|
|
+ ESP_LOGI(TAG, "MQTT_EVENT_UNSUBSCRIBED, msg_id=%d", event->msg_id);
|
|
|
+ break;
|
|
|
+ case MQTT_EVENT_PUBLISHED:
|
|
|
+ ESP_LOGI(TAG, "MQTT_EVENT_PUBLISHED, msg_id=%d", event->msg_id);
|
|
|
+ break;
|
|
|
+ case MQTT_EVENT_DATA:
|
|
|
+ ESP_LOGI(TAG, "MQTT_EVENT_DATA");
|
|
|
+ break;
|
|
|
+ case MQTT_EVENT_ERROR:
|
|
|
+ ESP_LOGI(TAG, "MQTT_EVENT_ERROR");
|
|
|
+ break;
|
|
|
+ default:
|
|
|
+ ESP_LOGI(TAG, "Other event id:%d", event->event_id);
|
|
|
+ break;
|
|
|
+ }
|
|
|
+ return ESP_OK;
|
|
|
+}
|
|
|
+
|
|
|
+static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) {
|
|
|
+ ESP_LOGD(TAG, "Event dispatched from event loop base=%s, event_id=%d", base, event_id);
|
|
|
+ mqtt_event_handler_cb((esp_mqtt_event_handle_t)event_data);
|
|
|
+}
|
|
|
+
|
|
|
+static void mqtt_app_start(void)
|
|
|
+{
|
|
|
+ esp_mqtt_client_config_t mqtt_cfg = { };
|
|
|
+
|
|
|
+ esp_mqtt_client_handle_t client = esp_mqtt_client_init(&mqtt_cfg);
|
|
|
+ esp_mqtt_client_register_event(client, MQTT_EVENT_ANY, mqtt_event_handler, client);
|
|
|
+ esp_mqtt_client_start(client);
|
|
|
+ esp_mqtt_set_config(client, &mqtt_cfg);
|
|
|
+ int msg_id = esp_mqtt_client_publish(client, "/topic/qos1", "data", 0, 0, 0);
|
|
|
+ ESP_LOGI(TAG, "mqtt api returned %d", msg_id);
|
|
|
+ msg_id = esp_mqtt_client_subscribe(client, "/topic/qos0", 0);
|
|
|
+ ESP_LOGI(TAG, "mqtt api returned %d", msg_id);
|
|
|
+ msg_id = esp_mqtt_client_subscribe(client, "/topic/qos1", 1);
|
|
|
+ ESP_LOGI(TAG, "mqtt api returned %d", msg_id);
|
|
|
+ msg_id = esp_mqtt_client_unsubscribe(client, "/topic/qos1");
|
|
|
+ ESP_LOGI(TAG, "mqtt api returned %d", msg_id);
|
|
|
+ esp_err_t err = esp_mqtt_client_set_uri(client, "mqtt://localhost:1883");
|
|
|
+ ESP_LOGI(TAG, "mqtt api returned %d", err);
|
|
|
+ err = esp_mqtt_client_reconnect(client);
|
|
|
+ err = esp_mqtt_client_disconnect(client);
|
|
|
+ err = esp_mqtt_client_stop(client);
|
|
|
+ err = esp_mqtt_client_destroy(client);
|
|
|
+}
|
|
|
+
|
|
|
+extern "C" void app_main(void)
|
|
|
+{
|
|
|
+ ESP_LOGI(TAG, "[APP] Startup..");
|
|
|
+ ESP_LOGI(TAG, "[APP] Free memory: %d bytes", esp_get_free_heap_size());
|
|
|
+ ESP_LOGI(TAG, "[APP] IDF version: %s", esp_get_idf_version());
|
|
|
+
|
|
|
+ esp_log_level_set("*", ESP_LOG_INFO);
|
|
|
+ esp_log_level_set("MQTT_CLIENT", ESP_LOG_VERBOSE);
|
|
|
+ esp_log_level_set("MQTT_EXAMPLE", ESP_LOG_VERBOSE);
|
|
|
+ esp_log_level_set("TRANSPORT_TCP", ESP_LOG_VERBOSE);
|
|
|
+ esp_log_level_set("TRANSPORT_SSL", ESP_LOG_VERBOSE);
|
|
|
+ esp_log_level_set("TRANSPORT", ESP_LOG_VERBOSE);
|
|
|
+ esp_log_level_set("OUTBOX", ESP_LOG_VERBOSE);
|
|
|
+
|
|
|
+ ESP_ERROR_CHECK(nvs_flash_init());
|
|
|
+ ESP_ERROR_CHECK(esp_netif_init());
|
|
|
+ ESP_ERROR_CHECK(esp_event_loop_create_default());
|
|
|
+
|
|
|
+ mqtt_app_start();
|
|
|
+}
|