车辆上报判断是否现成,否则会创建多余线程
parent
6ba8a8b35d
commit
36834b9bd5
|
@ -119,7 +119,7 @@ public class VehicleInstanceServiceImpl implements VehicleInstanceService {
|
||||||
.build();
|
.build();
|
||||||
Result<String> result = clientAdmin.vehicleConnection(connectionReq);
|
Result<String> result = clientAdmin.vehicleConnection(connectionReq);
|
||||||
if (result.getCode() != 200){
|
if (result.getCode() != 200){
|
||||||
throw new RuntimeException("车辆:["+vin+"],连接异常:["+result.getMsg()+"]");
|
log.error("车辆:[{}],申请上线异常:[{}]", vin, result.getMsg());
|
||||||
}
|
}
|
||||||
MqttProperties mqttProperties = MqttProperties.builder()
|
MqttProperties mqttProperties = MqttProperties.builder()
|
||||||
.broker(broker)
|
.broker(broker)
|
||||||
|
|
Loading…
Reference in New Issue