修改消息确认逻辑

src/main/java/com/fdkankan/contro/listener/RabbitMqListener.java

@@ -60,9 +60,9 @@ public class RabbitMqListener {
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
         log.info("场景计算资源准备开始，队列名：{}，id：{},消息体:{}", queueModelingPre, correlationId, msg);
         BuildSceneCallMessage buildSceneMessage = JSONObject.parseObject(msg, BuildSceneCallMessage.class);
+        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         Thread.sleep(2000L);
         buildScenePreService.buildScenePre(buildSceneMessage);
-        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
     }
 
     /**
@@ -81,9 +81,10 @@ public class RabbitMqListener {
         String msg = new String(message.getBody(), StandardCharsets.UTF_8);
         log.info("场景计算结果处理开始,队列名：{},id:{},消息体:{}", queueModelingPost, correlationId, msg);
         BuildSceneResultMqMessage resultMessage = JSONObject.parseObject(msg, BuildSceneResultMqMessage.class);
+        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         Thread.sleep(2000L);
         buildScenePostService.buildScenePost(resultMessage);
-        channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
+
     }
 
     /**