Przeglądaj źródła

修改消息处理逻辑

tianboguang 2 lat temu
rodzic
commit
7c9d10ab3a

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

@@ -79,8 +79,9 @@ public class RabbitMqListener {
             concurrency = "${maxThread.modeling.modeling-call}",
             priority = "${mq.consumerPriority}"
     )
-    public void buildSceneHandler(Channel channel, Message message, @Header(AmqpHeaders.DELIVERY_TAG) long deliveryTag) throws Exception {
+    public void buildSceneHandler(Channel channel, Message message) throws Exception {
         SysConstants.SYSTEM_BUILDING = true;
+        long deliveryTag = message.getMessageProperties().getDeliveryTag();
         if (SysConstants.SYSTEM_OFFING) {
             SysConstants.SYSTEM_BUILDING = false;
             channel.basicNack(deliveryTag, true, true);