1

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 {