From b8c5eb8048b566d632b25391a79ccbd6ce33c010 Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期六, 30 三月 2019 16:10:01 +0800
Subject: [PATCH] 1.3 增加nsq消息，解决进程重启
---
QiaoJiaSystem/VideoToImageMulth/main.cpp | 13 +++++++++++--
1 files changed, 11 insertions(+), 2 deletions(-)
diff --git a/QiaoJiaSystem/VideoToImageMulth/main.cpp b/QiaoJiaSystem/VideoToImageMulth/main.cpp
index cc8e031..bf77930 100644
--- a/QiaoJiaSystem/VideoToImageMulth/main.cpp
+++ b/QiaoJiaSystem/VideoToImageMulth/main.cpp
@@ -66,8 +66,8 @@
// std::string rtmpAddr = appConfig.getStringProperty("srsAddr");
// std::string publish_basepath = rtmpAddr + "" ;
// appPref.setStringData("publish.basepath", publish_basepath);
- appPref.setIntData("pulish.width", 640);
- appPref.setIntData("pulish.height", 360);
+// appPref.setIntData("pulish.width", 640);
+// appPref.setIntData("pulish.height", 480);
}
// int arg1 = atoi(argv[1]);
//
@@ -113,8 +113,13 @@
BaseSqliteDao::setLDBTool(&ldbTool);
t_value = VssLocalSettingTblSqliteDao::instance()->findAllVssLocalSettingTblList();
}
+ DBG("t_value.size():" << t_value.size());
+ DBG("t_value[\"data\"].size():" << t_value["data"].size());//todo bug here t_value["data"].size() = 0
if (t_value.size() == 1 && t_value["data"].size() > 1) {
assert("t_value.size()");
+ }
+ if (t_value["data"].size() == 0) {
+ assert("t_value[\"data\"].size()");
}
DBG(t_value["data"].begin()->toStyledString());
auto &t_cfg = *t_value["data"].begin();
@@ -160,6 +165,10 @@
}
DBG("test start");
+ // #todo
+// BasicMsg::Nsq::NsqMsgConsumer nsqMsgConsumer("127.0.0.1", "4150", "test3", "ch2");
+ //
+
appPref.setStringData("user.loop.absolute.path", appConfig.getStringProperty("cutPath"));
IceRpcServer<RtspAnalysManager> server("RtspAnalysServer", appPref.getIntData("RpcVTIMPort"), "tcp");
server.setMessageSizeMax(1024 * 1024 * 50);
--
Gitblit v1.8.0