From b5207fee2a453b9ffe4d976718b89f1e7bc893da Mon Sep 17 00:00:00 2001
From: Van0313 <60689272+Van0313@users.noreply.github.com>
Date: Wed, 30 Apr 2025 11:05:53 +0800
Subject: [PATCH] =?UTF-8?q?=E8=B6=85=E6=97=B6=E9=80=80=E5=87=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/cn/van/business/mq/MessageConsumerService.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java
index 1cb1b05..206bff8 100644
--- a/src/main/java/cn/van/business/mq/MessageConsumerService.java
+++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java
@@ -26,7 +26,7 @@ import static cn.van.business.util.WXUtil.WX_BASE_URL;
  */
 @Service
 @RocketMQMessageListener(topic = "wx-message", consumerGroup = "${rocketmq.consumer.group}", nameServer = "${rocketmq.name-server}", consumeMode = ConsumeMode.ORDERLY,  // 顺序消费模式
-        consumeThreadNumber = 1)
+        consumeThreadNumber = 4)
 public class MessageConsumerService implements RocketMQListener<JSONObject> {
 
     private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class);