111

src/main/java/com/fdkankan/contro/mq/listener/BuildSceneProcessLogListener.java

@@ -40,6 +40,8 @@ public class BuildSceneProcessLogListener{
     )
     public void buildScenePreHandler(Channel channel, Message message) throws Exception {
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
+        String messageId = message.getMessageProperties().getMessageId();
+        log.info("开始消费，队列名：{}，messageId:{}, msg:{}", queueModelingProcessLog, messageId, msg);
         BuildSceneProcessLogMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneProcessLogMessage.class);
         String num = buildSceneMessage.getNum();
         try {