diff --git a/src/ai_platform/MultiSourceProcess.cpp b/src/ai_platform/MultiSourceProcess.cpp
index b058fb7..8478a83 100644
--- a/src/ai_platform/MultiSourceProcess.cpp
+++ b/src/ai_platform/MultiSourceProcess.cpp
@@ -156,6 +156,10 @@ int CMultiSourceProcess::InitAlgorthim(tsl_aiplatform_param vptParam){
   m_snapshot_reprocessing = new snapshot_reprocessing(m_devId);
   m_save_snapshot_reprocessing = new save_snapshot_reprocessing(m_devId);
 
+#ifdef POST_USE_RABBITMQ
+    mq_manager_ = new mq::Manager();
+#endif
+
   VPCUtil* pVpcUtil = VPCUtil::getInstance();
   pVpcUtil->init(m_devId);
 
@@ -191,6 +195,12 @@ int CMultiSourceProcess::InitAlgorthim(tsl_aiplatform_param vptParam){
 /* MQ队列的初始化 */
 int CMultiSourceProcess::AddMqConn(mq_type_t mq_type, rabbitmq_conn_params_t mq_conn_param) {
   /* 初始化MQ队列 */
+  LOG_INFO("初始化MQ队列");
+  if(mq_manager_ == nullptr){
+    LOG_ERROR("mq_manager_ is null");
+    return FAILED;
+  }
+  
   if (!mq_manager_->add_conn(mq_type, mq_conn_param)) {
     LOG_ERROR("Connection MQ failed, ip: {} port: {} uname: {} passwd: {}", mq_conn_param.ip, mq_conn_param.port,
               mq_conn_param.uname, mq_conn_param.passwd);