修改消息确认逻辑

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

@@ -98,7 +98,7 @@ public class RabbitMqListener {
             concurrency = "${maxThread.modeling.modeling-call}",
             priority = "${mq.consumerPriority}"
     )
-    public void buildSceneHandler(Channel channel, Envelope envelope, Message message, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) throws Exception {
+    public void buildSceneHandler(Channel channel, Message message, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) throws Exception {
         SysConstants.SYSTEM_BUILDING = true;
         if (SysConstants.SYSTEM_OFFING) {
             SysConstants.SYSTEM_BUILDING = false;
@@ -124,7 +124,7 @@ public class RabbitMqListener {
         this.process(buildSceneMessage);
         log.info("场景计算结束,队列名:{},id:{}", queueModelingCall, correlationId);
 
-        channel.basicAck(envelope.getDeliveryTag(), false);
+        channel.basicAck(deliveryTag, false);
 
         //计算完毕，将当前系统构建状态改为false
         SysConstants.SYSTEM_BUILDING = false;