// mqtt_client_wrapper.hpp
#pragma once

#include <atomic>
#include <memory>

#include "app_config.hpp"
#include "data_manager.hpp"
#include "logger.hpp"
#include "mqtt_client.hpp"
#include "rtmp_manager.hpp"

// 启动 MQTT 客户端线程（内部自动重连、订阅等）
void mqtt_client_thread_func();