소스 검색

修改消息确认逻辑

tianboguang 2 년 전
부모
커밋
9234de4600
1개의 변경된 파일3개의 추가작업 그리고 2개의 파일을 삭제
  1. 3 2
      src/main/java/com/fdkankan/modeling/receiver/RabbitMqListener.java

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

@@ -120,12 +120,13 @@ public class RabbitMqListener {
             log.error("消息内容错误,id:{},消息体:{}", correlationId, msg);
             return;
         }
+        // 提前确认消息,以免执行超时重发
+        channel.basicAck(deliveryTag, false);
+
         log.info("场景计算开始,队列名:{},id:{},消息体:{}", queueModelingCall, correlationId,msg);
         this.process(buildSceneMessage);
         log.info("场景计算结束,队列名:{},id:{}", queueModelingCall, correlationId);
 
-        channel.basicAck(deliveryTag, false);
-
         //计算完毕,将当前系统构建状态改为false
         SysConstants.SYSTEM_BUILDING = false;
     }