From e15c4888f720b8781260b901ac82d058f8f7c3b5 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期三, 27 三月 2019 14:34:37 +0800
Subject: [PATCH] 移植nsq到项目中,将最短最长时长的参数修改成nsq配置

---
 QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h |   13 +++++++++++++
 1 files changed, 13 insertions(+), 0 deletions(-)

diff --git a/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h b/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h
index fbd73ba..94f3750 100644
--- a/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h
+++ b/QiaoJiaSystem/VideoToImageMulth/RtspAnalysManager.h
@@ -15,6 +15,8 @@
 #include <QiaoJia/DB/LDBTool.h>
 #include <basic/util/app/AppPreference.hpp>
 #include "RtspAnalysServer.h"
+
+#include "NsqMsgTool.hpp"
 //#include <GB28181DecoderModel/VideoCaptureElementWithRtp.h>
 //#include <VideoToImageMulth/rpc/RtspAnalysServer.h>
 
@@ -28,6 +30,13 @@
     RtspAnalysManager() : m_maxCount(50), m_currentCount(0) {
         m_lDBTool = new LDBTool;
         init();
+
+        //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")));
+        nsqMsgConsumer->setMessageCallback(std::bind(&OnMsgFunc, std::placeholders::_1, this));
+        nsqMsgConsumer->init();
+        DBG("NsqMsgConsumer Init END!!");
     }
 
     RtspAnalysManager(LDBTool *_dbTool);
@@ -51,9 +60,13 @@
 
 private:
     void init();
+    static void OnMsgFunc(void *msgPtr, void *pThisPtr);
 
 private:
 
+    //nsq
+    BasicMsg::Nsq::NsqMsgConsumer *nsqMsgConsumer;
+
     RWLock m_imgRedisCRwLock;
 
     LDBTool *m_lDBTool;

--
Gitblit v1.8.0