From b5ac5f7d1e0f79d332dcddc3dabd8709b1e2a2ea Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期三, 10 四月 2019 19:42:29 +0800
Subject: [PATCH] 解决nsg消费者的topic名称带有./的bug 注释一些错误打印

---
 QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.cpp |   15 +++++++++++++--
 1 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.cpp b/QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.cpp
index 572401b..ef06eb9 100644
--- a/QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.cpp
+++ b/QiaoJiaSystem/VideoAnalysFromHC/RtspAnalysElement.cpp
@@ -33,8 +33,19 @@
         //nsq   set callback func
         DBG("NsqMsgConsumer Init");
         string pName(argv[0]);
-        nsqMsgConsumer = new BasicMsg::Nsq::NsqMsgConsumer("127.0.0.1", "4150", pName,
-                                                           to_string(appPref.getIntData("RpcVTIMPort")));
+        if(argv[0][0] == '.' && argv[0][1] == '/')
+        {
+            string pName(argv[0]+2, argv[0]+strlen(argv[0]));
+            DBG("pName(argv[0]) :" << pName);
+            nsqMsgConsumer = new BasicMsg::Nsq::NsqMsgConsumer("127.0.0.1", "4150", pName,
+                                                               to_string(appPref.getIntData("RpcVTIMPort")));
+        }else{
+            string pName(argv[0]);
+            DBG("pName(argv[0]) :" << pName);
+            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!!");

--
Gitblit v1.8.0