修改消息确认机制

src/main/java/com/fdkankan/modeling/receiver/RabbitMqListener.java

@@ -89,6 +89,9 @@ public class RabbitMqListener {
             log.error("服务实例：{} 正在关闭，退出构建！", SysConstants.hostName);
             return;
         }
+        // 提前确认消息，以免执行超时重发
+        channel.basicAck(deliveryTag, false);
+
         if (ObjectUtils.isEmpty(message.getBody())) {
             SysConstants.SYSTEM_BUILDING = false;
             log.error("消息内容为空,退出构建,当前服务器id:{}", SysConstants.hostName);
@@ -102,8 +105,7 @@ public class RabbitMqListener {
             log.error("消息内容错误,id:{},消息体:{}", messageId, msg);
             return;
         }
-        // 提前确认消息，以免执行超时重发
-        channel.basicAck(deliveryTag, false);
+
         BuildLog buildLog = new BuildLog();
         log.info("场景计算开始,队列名:{},id:{},deliveryTag:{},消息体:{}", queueModelingCall, messageId,deliveryTag,msg);
         buildLog.setMessageId(messageId);