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;