This commit is contained in:
cxh 2025-11-13 13:22:17 +08:00
parent b38fa77a83
commit 1790f7b318

View File

@ -66,7 +66,7 @@ static void send_heartbeat()
static void on_mqtt_connected() static void on_mqtt_connected()
{ {
LOG_INFO("[MQTT] Connected to broker: " + g_app_config.mqtt.server_ip); LOG_INFO("[MQTT] Connected to broker: " + g_app_config.mqtt.server_ip);
mqtt_client->subscribe(g_app_config.mqtt.topics.video_down) mqtt_client->subscribe(g_app_config.mqtt.topics.video_down);
} }
static void on_mqtt_disconnected() { LOG_WARN("[MQTT] Disconnected from broker: " + g_app_config.mqtt.server_ip); } static void on_mqtt_disconnected() { LOG_WARN("[MQTT] Disconnected from broker: " + g_app_config.mqtt.server_ip); }