| | |
|---|
| | | }else{ |
|---|
| | | mqVo.svUserPassword = mqVo.svUserPassword.trim() ; |
|---|
| | | } |
|---|
| | | mqVo.poolMaxSize = conf.getSetAttrPlusInt(doc, "config.mqtt", "poolMaxSize", null, 5, 360000, null); |
|---|
| | | if(mqVo.poolMaxSize <= 1 || mqVo.poolMaxSize > 1000){ |
|---|
| | | throw new Exception("config.mqtt.poolMaxSize配置的连接池连接最大数量不合法") ; |
|---|
| | | } |
|---|
| | | mqVo.poolMaxSize = conf.getSetAttrPlusInt(doc, "config.mqtt", "poolMaxSize", null, 1, 1000, null); |
|---|
| | | |
|---|
| | | mqVo.sendInterval = conf.getSetAttrPlusInt(doc, "config.mqtt", "sendInterval", null, 1, 3600, null) * 1000L ; |
|---|
| | | |
|---|
| | | mqVo.reSendTimesByNoResult = conf.getSetAttrPlusInt(doc, "config.mqtt", "reSendTimesByNoResult", null, 0, 100, null); |
|---|
| | | |
|---|
| | | mqVo.comCacheTimeout = conf.getSetAttrPlusInt(doc, "config.mqtt", "comCacheTimeout", null, 1, 3600, null) * 1000L ; |
|---|
| | | |
|---|
| | | mqVo.useMemoryPersistence = conf.getSetAttrBoolean(doc, "config.mqtt", "useMemoryPersistence", null, null) ; |
|---|
| | | String proAndDevIds = conf.getSetAttrTxt(doc, "config.mqtt", "protocolAndDeviceIds", null, false, null) ; |
|---|
| | | if(proAndDevIds == null || proAndDevIds.trim().equals("")){ |
|---|
