feat():连接mqtt配置信息更正
parent
525a4eeb5a
commit
0f26982a39
1
pom.xml
1
pom.xml
|
@ -66,6 +66,7 @@
|
||||||
<dependency>
|
<dependency>
|
||||||
<groupId>com.h2database</groupId>
|
<groupId>com.h2database</groupId>
|
||||||
<artifactId>h2</artifactId>
|
<artifactId>h2</artifactId>
|
||||||
|
<version>2.1.214</version>
|
||||||
</dependency>
|
</dependency>
|
||||||
|
|
||||||
<dependency>
|
<dependency>
|
||||||
|
|
|
@ -119,7 +119,7 @@ public class VehicleInstanceServiceImpl implements VehicleInstanceService {
|
||||||
}
|
}
|
||||||
MqttServerModel mqttServerModel = result.getData();
|
MqttServerModel mqttServerModel = result.getData();
|
||||||
MqttProperties mqttProperties = MqttProperties.builder()
|
MqttProperties mqttProperties = MqttProperties.builder()
|
||||||
.broker(mqttServerModel.getBroker())
|
.broker("tcp://"+mqttServerModel.getBroker()+":1883")
|
||||||
.topic(mqttServerModel.getTopic())
|
.topic(mqttServerModel.getTopic())
|
||||||
.clientId(vin)
|
.clientId(vin)
|
||||||
.username(connectionReq.getUserName())
|
.username(connectionReq.getUserName())
|
||||||
|
|
Loading…
Reference in New Issue