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