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