From 0f26982a392403237e65b424fd5adf79ef23718f Mon Sep 17 00:00:00 2001
From: Saisai Liu <1374434128@qq.com>
Date: Tue, 4 Jun 2024 08:50:05 +0800
Subject: [PATCH] =?UTF-8?q?feat():=E8=BF=9E=E6=8E=A5mqtt=E9=85=8D=E7=BD=AE?=
 =?UTF-8?q?=E4=BF=A1=E6=81=AF=E6=9B=B4=E6=AD=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 pom.xml                                                         | 1 +
 .../java/com/muyu/service/impl/VehicleInstanceServiceImpl.java  | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/pom.xml b/pom.xml
index a44615c..36df5b2 100644
--- a/pom.xml
+++ b/pom.xml
@@ -66,6 +66,7 @@
         <dependency>
             <groupId>com.h2database</groupId>
             <artifactId>h2</artifactId>
+            <version>2.1.214</version>
         </dependency>
 
         <dependency>
diff --git a/src/main/java/com/muyu/service/impl/VehicleInstanceServiceImpl.java b/src/main/java/com/muyu/service/impl/VehicleInstanceServiceImpl.java
index f652a61..7ebdb55 100644
--- a/src/main/java/com/muyu/service/impl/VehicleInstanceServiceImpl.java
+++ b/src/main/java/com/muyu/service/impl/VehicleInstanceServiceImpl.java
@@ -119,7 +119,7 @@ public class VehicleInstanceServiceImpl implements VehicleInstanceService {
         }
         MqttServerModel mqttServerModel = result.getData();
         MqttProperties mqttProperties = MqttProperties.builder()
-                .broker(mqttServerModel.getBroker())
+                .broker("tcp://"+mqttServerModel.getBroker()+":1883")
                 .topic(mqttServerModel.getTopic())
                 .clientId(vin)
                 .username(connectionReq.getUserName())