2025-10-16 10:25:51 +08:00
|
|
|
// mqtt_client_wrapper.hpp
|
2025-09-08 10:59:08 +08:00
|
|
|
#pragma once
|
|
|
|
|
|
2025-10-15 17:01:43 +08:00
|
|
|
#include <atomic>
|
|
|
|
|
#include <memory>
|
|
|
|
|
|
2025-09-08 15:09:33 +08:00
|
|
|
#include "app_config.hpp"
|
2025-10-16 10:31:48 +08:00
|
|
|
#include "data_manager.hpp"
|
2025-09-08 10:59:08 +08:00
|
|
|
#include "logger.hpp"
|
|
|
|
|
#include "mqtt_client.hpp"
|
2025-10-14 17:13:08 +08:00
|
|
|
#include "rtmp_manager.hpp"
|
2025-10-15 17:01:43 +08:00
|
|
|
|
2025-09-08 15:09:33 +08:00
|
|
|
// 启动 MQTT 客户端线程（内部自动重连、订阅等）
|
2025-09-08 10:59:08 +08:00
|
|
|
void mqtt_client_thread_func();
|
