eeeck/the-waterinator
1
1
Fork 0
Code Issues 1 Pull Requests Actions Packages Projects Releases Wiki Activity

Subscribe to topics

Browse Source
This commit is contained in:
Erick
2025-12-13 12:37:51 +01:00
parent dc5c2c751b
commit cd36415807
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
firmware/esp32/main/mqtt.cpp
+5 -3
View File
@@ -14,10 +14,11 @@ static const char* TAG = "MQTT";
static esp_mqtt_client_handle_t mqtt_client = NULL; static esp_mqtt_client_handle_t mqtt_client = NULL;
static char global_rx_buffer[50]; static char rx_buffer[50];
static void mqtt_subscribe(void) { static void mqtt_subscribe(void) {
esp_mqtt_client_subscribe(mqtt_client, "/topic/qos0", 0); esp_mqtt_client_subscribe(mqtt_client, "/plant/moisture/qos0", 0);
esp_mqtt_client_subscribe(mqtt_client, "/plant/humidity/qos0", 0);
} }
static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) { static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) {
@@ -26,8 +27,9 @@ static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_
switch(event->event_id) { switch(event->event_id) {
case MQTT_EVENT_CONNECTED: case MQTT_EVENT_CONNECTED:
xEventGroupSetBits(connectivity_event_group, MQTT_CONNECTED_BIT); xEventGroupSetBits(connectivity_event_group, MQTT_CONNECTED_BIT);
mqtt_subscribe();
ESP_LOGV(TAG, "Connected to broker"); ESP_LOGV(TAG, "Connected to broker");
mqtt_subscribe();
ESP_LOGV(TAG, "Subscribed to topic");
break; break;
case MQTT_EVENT_DISCONNECTED: case MQTT_EVENT_DISCONNECTED: