From 0b22477ca405333f842da06e15fa5da689061297 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E9=BE=99?= <lilong@axzo.cn>
Date: Wed, 22 Jan 2025 18:10:02 +0800
Subject: [PATCH] =?UTF-8?q?feat:(feature/REQ-3342)=20=E6=B6=88=E8=B4=B9?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=94=B9=E6=88=90=E9=A1=BA=E5=BA=8F=E6=B6=88?=
 =?UTF-8?q?=E8=B4=B9=EF=BC=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/axzo/tyr/server/config/RocketMQEventConfiguration.java  | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
index d5fd9be0..64564de8 100644
--- a/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
+++ b/tyr-server/src/main/java/cn/axzo/tyr/server/config/RocketMQEventConfiguration.java
@@ -71,7 +71,6 @@ public class RocketMQEventConfiguration {
     @RocketMQMessageListener(topic = "topic_thrones_${spring.profiles.active}",
             consumerGroup = "GID_topic_thrones_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
-            consumeMode = ConsumeMode.ORDERLY,
             nameServer = "${rocketmq.name-server}"
     )
     public static class ThronesListener extends BaseListener implements RocketMQListener<MessageExt> {
@@ -114,7 +113,6 @@ public class RocketMQEventConfiguration {
     @RocketMQMessageListener(topic = "topic_tyr_${spring.profiles.active}",
             consumerGroup = "GID_topic_tyr_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
-            consumeMode = ConsumeMode.ORDERLY,
             nameServer = "${rocketmq.name-server}"
     )
     public static class TyrListener extends BaseListener implements RocketMQListener<MessageExt> {
@@ -157,7 +155,6 @@ public class RocketMQEventConfiguration {
     @RocketMQMessageListener(topic = "topic_apisix_plat_${spring.profiles.active}",
             consumerGroup = "GID_topic_apisix_plat_${spring.application.name}_${spring.profiles.active}",
             messageModel = MessageModel.BROADCASTING,
-            consumeMode = ConsumeMode.ORDERLY,
             nameServer = "${rocketmq.name-server}"
     )
     public static class ApiSixPlatListener extends BaseListener implements RocketMQListener<MessageExt> {