comparison: main/task_mqtt.c
main/task_mqtt.c
- changeset 3
- cd760fd45271
- parent 2
- c0184362d48c
- child 4
- 2a57c466bf45
equal
deleted
inserted
replaced
| 2:c0184362d48c | 3:cd760fd45271 |
|---|---|
| 219 switch (event->event_id) { | 219 switch (event->event_id) { |
| 220 | 220 |
| 221 case MQTT_EVENT_CONNECTED: | 221 case MQTT_EVENT_CONNECTED: |
| 222 ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED"); | 222 ESP_LOGI(TAG, "MQTT_EVENT_CONNECTED"); |
| 223 xEventGroupSetBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); | 223 xEventGroupSetBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); |
| 224 | |
| 225 // topic = topic_base((char *)"NCMD"); | |
| 226 // topic = xstrcat(topic, (char *)"/#"); | |
| 227 // ESP_LOGI(TAG, "Subscribe %s", topic); | |
| 228 // msg_id = esp_mqtt_client_subscribe(client, topic, 0); | |
| 229 // ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id); | |
| 230 // free(topic); | |
| 231 | |
| 232 // topic = topic_base((char *)"DCMD"); | |
| 233 // topic = xstrcat(topic, (char *)"/#"); | |
| 234 // ESP_LOGI(TAG, "Subscribe %s", topic); | |
| 235 // msg_id = esp_mqtt_client_subscribe(client, topic, 1); | |
| 236 // ESP_LOGI(TAG, "sent subscribe successful, msg_id=%d", msg_id); | |
| 237 // free(topic); | |
| 238 // topic = NULL; | |
| 239 break; | 224 break; |
| 240 | 225 |
| 241 case MQTT_EVENT_DISCONNECTED: | 226 case MQTT_EVENT_DISCONNECTED: |
| 242 ESP_LOGI(TAG, "MQTT_EVENT_DISCONNECTED"); | 227 ESP_LOGI(TAG, "MQTT_EVENT_DISCONNECTED"); |
| 243 xEventGroupClearBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); | 228 xEventGroupClearBits(xEventGroupMQTT, TASK_MQTT_CONNECTED); |
| 264 case MQTT_EVENT_ERROR: | 249 case MQTT_EVENT_ERROR: |
| 265 ESP_LOGI(TAG, "MQTT_EVENT_ERROR"); | 250 ESP_LOGI(TAG, "MQTT_EVENT_ERROR"); |
| 266 break; | 251 break; |
| 267 | 252 |
| 268 case MQTT_EVENT_BEFORE_CONNECT: | 253 case MQTT_EVENT_BEFORE_CONNECT: |
| 269 ESP_LOGI(TAG, "MQTT_EVENT_BEFORE_CONNECT"); | 254 //ESP_LOGI(TAG, "MQTT_EVENT_BEFORE_CONNECT"); |
| 270 // Configure connection can be here. | 255 // Configure connection can be here. |
| 271 break; | 256 break; |
| 272 | 257 |
| 273 default: | 258 default: |
| 274 ESP_LOGI(TAG, "Other event id:%d", event->event_id); | 259 ESP_LOGI(TAG, "Other event id:%d", event->event_id); |
| 278 } | 263 } |
| 279 | 264 |
| 280 | 265 |
| 281 | 266 |
| 282 static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) { | 267 static void mqtt_event_handler(void *handler_args, esp_event_base_t base, int32_t event_id, void *event_data) { |
| 283 ESP_LOGI(TAG, "Event dispatched from event loop base=%s, event_id=%d", base, event_id); | 268 // ESP_LOGI(TAG, "Event dispatched from event loop base=%s, event_id=%d", base, event_id); |
| 284 mqtt_event_handler_cb(event_data); | 269 mqtt_event_handler_cb(event_data); |
| 285 } | 270 } |
| 286 | 271 |
| 287 | 272 |
| 288 | 273 |
