Ver código fonte

取消提前确认逻辑

tianboguang 2 anos atrás
pai
commit
c0486c34ae

+ 2 - 2
src/main/java/com/fdkankan/modeling/receiver/RabbitMqListener.java

@@ -88,8 +88,6 @@ public class RabbitMqListener {
             log.error("服务实例:{} 正在关闭,退出构建!", SysConstants.hostName);
             return;
         }
-        // 提前确认消息,以免执行超时重发
-        channel.basicAck(deliveryTag, false);
 
         if (ObjectUtils.isEmpty(message.getBody())) {
             SysConstants.SYSTEM_BUILDING = false;
@@ -115,6 +113,8 @@ public class RabbitMqListener {
 
         //计算完毕,将当前系统构建状态改为false
         SysConstants.SYSTEM_BUILDING = false;
+
+        channel.basicAck(deliveryTag, false);
     }
 
     public void process(BuildSceneCallMessage message,BuildLog buildLog) {