修改消息id获取逻辑

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

@@ -17,10 +17,9 @@ import java.util.HashMap;
 public class AbstrackBuildSceneListener implements IBuildSceneListener {
     @Override
     public void preHandle(Channel channel, String queueName, Message message, IBuildSceneService buildSceneService) throws IOException {
-        Object correlation = message.getMessageProperties().getHeader("spring_returned_message_correlation");
-        String correlationId = (String) correlation;
+        String messageId = message.getMessageProperties().getMessageId();
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
-        log.info("开始准备场景计算资源，队列名：{}，id：{},消息体:{}", queueName, correlationId, msg);
+        log.info("开始准备场景计算资源，队列名：{}，id：{},消息体:{}", queueName, messageId, msg);
         BuildSceneCallMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneCallMessage.class);
         channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         if(ObjectUtils.isEmpty(buildSceneMessage.getBuildContext())){
@@ -30,18 +29,17 @@ public class AbstrackBuildSceneListener implements IBuildSceneListener {
             buildSceneMessage.getBuildContext().put("sceneNum",buildSceneMessage.getSceneNum());
         }
         buildSceneService.buildScenePre(buildSceneMessage);
-        log.info("准备场景计算资源完成，队列名：{}，id：{},消息体:{}", queueName, correlationId, msg);
+        log.info("准备场景计算资源完成，队列名：{}，id：{},消息体:{}", queueName, messageId, msg);
     }
 
     @Override
     public void postHandle(Channel channel, String queueName, Message message, IBuildSceneService buildSceneService) throws Exception {
-        Object correlation = message.getMessageProperties().getHeader("spring_returned_message_correlation");
-        String correlationId = (String) correlation;
+        String messageId = message.getMessageProperties().getMessageId();
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
-        log.info("场景计算完成，开始处理场景计算结果，队列名：{}，id：{},消息体:{}", queueName, correlationId, msg);
+        log.info("场景计算完成，开始处理场景计算结果，队列名：{}，id：{},消息体:{}", queueName, messageId, msg);
         BuildSceneResultMqMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneResultMqMessage.class);
         channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         buildSceneService.buildScenePost(buildSceneMessage);
-        log.info("场景计算结果处理完成，队列名：{}，id：{},消息体:{}", queueName, correlationId, msg);
+        log.info("场景计算结果处理完成，队列名：{}，id：{},消息体:{}", queueName, messageId, msg);
     }
 }