From 5425000787e11828e48822fec1f1ab921af6d651 Mon Sep 17 00:00:00 2001
From: sige <sige@sige.com>
Date: Wed, 17 Apr 2024 16:00:13 +0800
Subject: [PATCH] ~

---
 src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java | 4 ++--
 src/main/resources/application-dev.yml                            | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
index fdbeab3..31691fc 100644
--- a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
+++ b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
@@ -68,8 +68,8 @@ public class DigestionTaskTheadManager {
         });
         try {
             MqttConnectOptions options = new MqttConnectOptions();
-            options.setUserName(this.mqttBrokerUsername);
-            options.setPassword(this.mqttBrokerPassword.toCharArray());
+//            options.setUserName(this.mqttBrokerUsername);
+//            options.setPassword(this.mqttBrokerPassword.toCharArray());
             client.connect(options);
         } catch (MqttException e) {
             throw new RuntimeException(e);
diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml
index 06258ed..4004e56 100644
--- a/src/main/resources/application-dev.yml
+++ b/src/main/resources/application-dev.yml
@@ -25,7 +25,7 @@ device:
       port: 20000
 
 mqtt-broker:
-  uri: tcp://broker.emqx.io:1883
+  uri: mqtt://192.168.8.10:1883
   username: admin
   password: public
   clientId: digester