抽取统计打印方法
This commit is contained in:
@@ -31,7 +31,7 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
|
||||
|
||||
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;
|
||||
|
||||
Reference in New Issue
Block a user