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