修改配置
This commit is contained in:
parent
1a241f809b
commit
f4820b809f
|
|
@ -65,7 +65,7 @@ public class DjiService {
|
|||
DjiMqttClientConfig config = DjiMqttClientConfig.builder()
|
||||
.host(mqttProperties.getHost())
|
||||
.port(mqttProperties.getPort())
|
||||
.clientId(mqttProperties.getClientId())
|
||||
.clientId(mqttProperties.getClientId() + "_" + System.currentTimeMillis())
|
||||
.username(mqttProperties.getUsername())
|
||||
.password(mqttProperties.getPassword())
|
||||
.connectionTimeout(mqttProperties.getConnectionTimeout())
|
||||
|
|
|
|||
|
|
@ -89,7 +89,7 @@ public class TuohengService {
|
|||
TuohengMqttClientConfig config = TuohengMqttClientConfig.builder()
|
||||
.host(mqttProperties.getHost())
|
||||
.port(mqttProperties.getPort())
|
||||
.clientId(mqttProperties.getClientId())
|
||||
.clientId(mqttProperties.getClientId() + "_" + System.currentTimeMillis())
|
||||
.username(mqttProperties.getUsername())
|
||||
.password(mqttProperties.getPassword())
|
||||
.connectionTimeout(mqttProperties.getConnectionTimeout())
|
||||
|
|
|
|||
Loading…
Reference in New Issue