|  |  |  | 
|---|
|  |  |  | newLine = "tcp.port=" + paramMap.get(ParamKey.TcpPort); | 
|---|
|  |  |  | }else if(newLine != null && newLine.trim().startsWith("base.upData.min.interval=")){ | 
|---|
|  |  |  | newLine = "base.upData.min.interval=" + paramMap.get(ParamKey.UpDataMinInterval); | 
|---|
|  |  |  | }else if(newLine != null && newLine.trim().startsWith("mqtt.enable=")){ | 
|---|
|  |  |  | newLine = "mqtt.enable=" + paramMap.get(ParamKey.MqttEnable); | 
|---|
|  |  |  | }else if(newLine != null && newLine.trim().startsWith("mqtt.ip=")){ | 
|---|
|  |  |  | newLine = "mqtt.ip=" + paramMap.get(ParamKey.mqttServerIp); | 
|---|
|  |  |  | }else if(newLine != null && newLine.trim().startsWith("mqtt.port=")){ | 
|---|
|  |  |  | newLine = "mqtt.port=" + paramMap.get(ParamKey.mqttServerPort); | 
|---|
|  |  |  | }else if(newLine != null && newLine.trim().startsWith("mqtt.protocolAndDeviceIds=")){ | 
|---|
|  |  |  | newLine = "mqtt.protocolAndDeviceIds=" + paramMap.get(ParamKey.mqttProtocolAndDeviceIds); | 
|---|
|  |  |  | }else if(newLine != null && newLine.trim().startsWith("mqtt.subTopicAndQos=")){ | 
|---|
|  |  |  | newLine = "mqtt.subTopicAndQos=" + paramMap.get(ParamKey.mqttSubTopicAndQos); | 
|---|
|  |  |  | }else if(newLine != null && newLine.trim().startsWith("mqtt.noSubThenOff=")){ | 
|---|
|  |  |  | newLine = "mqtt.noSubThenOff=" + paramMap.get(ParamKey.MqttNoSubThenOff); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | newLines.add(newLine); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | key = ParamKey.DbName; | 
|---|
|  |  |  | this.getConfig(env, map, paramNamePre + key, key); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | key = ParamKey.MqttEnable; | 
|---|
|  |  |  | this.getConfig(env, map, paramNamePre + key, key); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | key = ParamKey.MqttNoSubThenOff; | 
|---|
|  |  |  | this.getConfig(env, map, paramNamePre + key, key); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | key = ParamKey.mqttProtocolAndDeviceIds; | 
|---|
|  |  |  | this.getConfig(env, map, paramNamePre + key, key); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | key = ParamKey.mqttServerIp; | 
|---|
|  |  |  | this.getConfig(env, map, paramNamePre + key, key); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | key = ParamKey.mqttServerPort; | 
|---|
|  |  |  | this.getConfig(env, map, paramNamePre + key, key); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | key = ParamKey.mqttSubTopicAndQos; | 
|---|
|  |  |  | this.getConfig(env, map, paramNamePre + key, key); | 
|---|
|  |  |  |  | 
|---|
|  |  |  | return map ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | private void getConfig(Environment env, Map<String, String> map, String paramName, String key) throws Exception{ | 
|---|