1.3 增加nsq消息，解决进程重启

chenshijun

2019-03-30 b8c5eb8048b566d632b25391a79ccbd6ce33c010

 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);