MQTT 消息日志记录

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;