From 00f7c180ceedecab842ce2a05308f435f9f54718 Mon Sep 17 00:00:00 2001 From: pansen <pansen626@sina.com> Date: 星期二, 09 四月 2019 14:24:19 +0800 Subject: [PATCH] # Type(<scope>): <subject> --- QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h | 9 +++++++-- 1 files changed, 7 insertions(+), 2 deletions(-) diff --git a/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h b/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h index 94f3750..dabe3ed 100644 --- a/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h +++ b/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h @@ -21,6 +21,8 @@ //#include <VideoToImageMulth/rpc/RtspAnalysServer.h> //using BASICGB28181::VideoCaptureElementWithRtp; +//澶栭儴浣跨敤鐨勫叏灞�鎸囬拡 +extern void *gRtspAnalysManagerCamera; //鐢ㄦ潵瀹炵幇recordVideo鐨凴PC鐨勬帴鍙g被 class RtspAnalysManager : public ::RtspAnalys::RtspAnalysServer { @@ -30,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!!"); @@ -60,6 +64,7 @@ private: void init(); + static void OnMsgFunc(void *msgPtr, void *pThisPtr); private: -- Gitblit v1.8.0