From 78cb96c5232e050e55cf7a550a5761207077cfbd Mon Sep 17 00:00:00 2001
From: sige <sige@sige.com>
Date: Thu, 30 May 2024 13:55:09 +0800
Subject: [PATCH] =?UTF-8?q?MQTT=20=E6=B6=88=E6=81=AF=E6=97=A5=E5=BF=97?=
 =?UTF-8?q?=E8=AE=B0=E5=BD=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

diff --git a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
index 30d85d3..e2ef30d 100644
--- a/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
+++ b/src/main/java/com/iflytop/digester/DigestionTaskTheadManager.java
@@ -100,6 +100,7 @@ public class DigestionTaskTheadManager {
     // Handle on message arrived
     private void handleOnMessageArrived(String topic, MqttMessage message) {
         MdbRuntimeLog.log("DigestionTaskMqttMessage", "Topic : %s; \nPayload : \n%s", topic, message.toString());
+        LOG.info("[DigestionTaskMqttMessage : (<-)] Topic : {}; Payload : {}", topic, message.toString());
 
         String content = new String(message.getPayload());
         JsonNode actionJsonTree = null;