From d4ddab0d84c6ab66adc7de420ce3f757d8283fc8 Mon Sep 17 00:00:00 2001
From: sige <sige@sige.com>
Date: Sat, 27 Apr 2024 17:06:05 +0800
Subject: [PATCH] 1

---
 app.db                                             | Bin 737280 -> 737280 bytes
 .../digester/DigestionTaskTheadManager.java        |   6 ++----
 2 files changed, 2 insertions(+), 4 deletions(-)

diff --git a/app.db b/app.db
index ca1d93e3cde3b8e6e4812f9b6490b9322c9987bf..d67aba3b53a64a36c79f1a8ea37ddc7f3acc6c26 100644
GIT binary patch
delta 56
zcmZo@&~0eYogmE^H&Mo!HI6~AtgA7lHHEP?g{d`#xiy8QHHEb`g{?J(y)}iSHHEV^
Lg==dH_Z)iw1XU6n

delta 56
zcmZo@&~0eYogmE^J5k1&HI_lozqT=@HHEP?g{d`#xiy8QHHEb`g{?J(y)}iSHHEV^
Lg==dH_Z)iw{0<T2

diff --git a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
index e39cb55..991699e 100644
--- a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
+++ b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
@@ -69,11 +69,9 @@ public class DigestionTaskTheadManager {
                 }
                 public void connectionLost(Throwable cause) {
                     UfMdbNotification.error("消解任务 MQTT 服务器断开连接");
-                    System.out.println("connectionLost: " + cause.getMessage());
-                }
-                public void deliveryComplete(IMqttDeliveryToken token) {
-                    System.out.println("xxxx");
+                    LOG.info("[MQTT Server] : connection lost {}", cause.getMessage());
                 }
+                public void deliveryComplete(IMqttDeliveryToken token) {}
             });
 
             try {