| | |
| | | ServerProperties.mqttAcceptDataMinInterval = conf.getSetAttrPlusInt(doc, "config.mqtt", "acceptDataMinInterval", null, 1, 720, null) * 60 * 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("")){ |
| | | throw new Exception("config.mqtt.protocolAndDeviceIds配置不合法") ; |
| | | }else{ |
| | | String proAndDevIds = conf.getSetAttrTxt(doc, "config.mqtt", "protocolAndDeviceIds", null, true, null) ; |
| | | if(proAndDevIds != null && !proAndDevIds.trim().equals("")){ |
| | | proAndDevIds = proAndDevIds.trim() ; |
| | | proAndDevIds = proAndDevIds.replaceAll(",", ","); |
| | | proAndDevIds = proAndDevIds.replaceAll(";", ";"); |
| | |
| | | } |
| | | } |
| | | |
| | | |
| | | String subTopicAndQos = conf.getSetAttrTxt(doc, "config.mqtt", "subTopicAndQos", null, false, null) ; |
| | | if(subTopicAndQos == null || subTopicAndQos.trim().equals("")){ |
| | | throw new Exception("config.mqtt.subTopicAndQos配置的主题及Qos不合法") ; |
| | | }else{ |
| | | String subTopicAndQos = conf.getSetAttrTxt(doc, "config.mqtt", "subTopicAndQos", null, true, null) ; |
| | | if(subTopicAndQos != null && !subTopicAndQos.trim().equals("")){ |
| | | subTopicAndQos = subTopicAndQos.trim() ; |
| | | subTopicAndQos = subTopicAndQos.replaceAll(",", ","); |
| | | subTopicAndQos = subTopicAndQos.replaceAll(";", ";"); |