From a26c680f12915788cc6126661d51a7672bb6ba8f Mon Sep 17 00:00:00 2001 From: pansen <pansen626@sina.com> Date: 星期三, 03 四月 2019 14:24:21 +0800 Subject: [PATCH] 修改VideoToImageMulth和VideoAnalysFrimHC的删除摄像机和编辑摄像机的nsq消息回调函数. --- QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h | 8 ++++++-- 1 files changed, 6 insertions(+), 2 deletions(-) diff --git a/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h b/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h index c17270a..dabe3ed 100644 --- a/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h +++ b/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h @@ -23,6 +23,7 @@ //using BASICGB28181::VideoCaptureElementWithRtp; //澶栭儴浣跨敤鐨勫叏灞�鎸囬拡 extern void *gRtspAnalysManagerCamera; + //鐢ㄦ潵瀹炵幇recordVideo鐨凴PC鐨勬帴鍙g被 class RtspAnalysManager : public ::RtspAnalys::RtspAnalysServer { @@ -31,10 +32,12 @@ RtspAnalysManager() : m_maxCount(50), m_currentCount(0) { m_lDBTool = new LDBTool; init(); - + IMPORT_APP_ARGS; //nsq set callback func DBG("NsqMsgConsumer Init"); - nsqMsgConsumer = new BasicMsg::Nsq::NsqMsgConsumer("127.0.0.1", "4150", "cut_dura_edit", to_string(appPref.getIntData("RpcVTIMPort"))); + string pName(argv[0]); + nsqMsgConsumer = new BasicMsg::Nsq::NsqMsgConsumer("127.0.0.1", "4150", pName, + to_string(appPref.getIntData("RpcVTIMPort"))); nsqMsgConsumer->setMessageCallback(std::bind(&OnMsgFunc, std::placeholders::_1, this)); nsqMsgConsumer->init(); DBG("NsqMsgConsumer Init END!!"); @@ -61,6 +64,7 @@ private: void init(); + static void OnMsgFunc(void *msgPtr, void *pThisPtr); private: -- Gitblit v1.8.0