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;