更新

7ef2a522 · KeYong · 8d83a490 · 7ef2a522
Commit 7ef2a522 authored Aug 23, 2021 by KeYong
Show whitespace changes
Inline Side-by-side

Showing with 9 additions and 2 deletions

SupervisionApplication.java ...rc/main/java/com/yeejoin/amos/SupervisionApplication.java +9 -2

No files found.
--- a/amos-boot-system-supervision/src/main/java/com/yeejoin/amos/SupervisionApplication.java
+++ b/amos-boot-system-supervision/src/main/java/com/yeejoin/amos/SupervisionApplication.java
@@ -96,7 +96,13 @@ public class SupervisionApplication {
     * @throws MqttException
     */
    @Bean
-    void initMqtt() throws MqttException
+    void initMqtt() {
-    { emqKeeper.getMqttClient().subscribe(airportTopic, 1, amosMqttListener); }
+        try {
+            emqKeeper.getMqttClient().subscribe(airportTopic, 1, amosMqttListener);
+        } catch (MqttException e) {
+            e.printStackTrace();
+            logger.error("EMQ初始化连接失败!");
+        }
+    }
 }
\ No newline at end of file