diff --git a/src/mqtt_client_wrapper.cpp b/src/mqtt_client_wrapper.cpp
index 88a7e83..51e582c 100644
--- a/src/mqtt_client_wrapper.cpp
+++ b/src/mqtt_client_wrapper.cpp
@@ -136,7 +136,7 @@ static void handle_record_query_request(const nlohmann::json& req)
     // 2. 计算 stream 名
     //    loc → stream，比如：
     //    0 → "AHD1_main"
-    std::string stream = RTMPManager::loc_to_stream(loc);
+    std::string stream = RecordManager::loc_to_stream(loc);
     if (stream.empty())
     {
         LOG_WARN("[record_query] invalid loc: " + std::to_string(loc));