sss

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);