| | |
|---|
| | | IMPORT_APP_ARGS; |
|---|
| | | //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"))); |
|---|
| | | DBG("argv[0]:" << argv[0]); |
|---|
| | | if(argv[0][0] == '.' && argv[0][1] == '/'){ |
|---|
| | | string pName(argv[0]+2, argv[0]+strlen(argv[0])); |
|---|
| | | DBG("pName:" << pName); |
|---|
| | | nsqMsgConsumer = new BasicMsg::Nsq::NsqMsgConsumer("127.0.0.1", "4150", pName, |
|---|
| | | to_string(appPref.getIntData("RpcVTIMPort"))); |
|---|
| | | }else{ |
|---|
| | | string pName(argv[0]); |
|---|
| | | DBG("pName:" << 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!!"); |
|---|
| | |
|---|
| | | for (auto itor_json = value.begin(); itor_json != itor_json_end; ++itor_json) { |
|---|
| | | //#todo 使用策略模式?发送端多个指令累积后发送? |
|---|
| | | if (itor_json->isString() && reader.parse(itor_json->asString(), cfg_val)) { |
|---|
| | | if (itor_json.name() == "cam_edit") { |
|---|
| | | if (itor_json.name() == "cam_edit" || itor_json.name() == "editSdkRule") { |
|---|
| | | string cam_idx = cfg_val["str_cam_dev_id"].asString(); |
|---|
| | | if (pthis->controllers.find(cam_idx) != pthis->controllers.end()) { |
|---|
| | | if (pthis->m_GB28181_Enable) { |
|---|
