From 30f5cb7a3d35658fd505385ea7caaf3e03f786b3 Mon Sep 17 00:00:00 2001 From: Leo Date: Sun, 16 Mar 2025 01:08:23 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8A=BD=E5=8F=96=E7=BB=9F=E8=AE=A1=E6=89=93?= =?UTF-8?q?=E5=8D=B0=E6=96=B9=E6=B3=95?= 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 aeab80c..9abff13 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -31,7 +31,7 @@ public class MessageConsumerService implements RocketMQListener { private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class); private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS - 0, // 预热期 5 秒 + 1, // 预热期 5 秒 TimeUnit.SECONDS); private final WxtsUtil wxtsUtil;