From 56d8222421309e962973e7fbdfd4eefb23bbf609 Mon Sep 17 00:00:00 2001
From: sige <sige@sige.com>
Date: Thu, 30 May 2024 18:17:15 +0800
Subject: [PATCH] sss

---
 src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
index 40c67fc..a96b667 100644
--- a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
+++ b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
@@ -229,6 +229,8 @@ public class DigestionTaskTheadManager {
                 "parameters", params
             );
             var messageJson = UfJsonHelper.objectToJson(message);
+            LOG.info("[DigestionTaskMqttMessage : (->)] Topic : {}; Payload : {}", transTopic, messageJson);
+
             MqttMessage mqttMessage = new MqttMessage(messageJson.getBytes());
             mqttMessage.setQos(2);
             this.client.publish(transTopic, mqttMessage);