diff --git a/im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java b/im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java index 353dcaf..29493ff 100644 --- a/im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java +++ b/im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java @@ -79,7 +79,7 @@ public class RedisMQPullTask implements CommandLineRunner { if (!EXECUTOR.isShutdown()) { if (datas.size() < batchSize) { // 数据已经消费完,等待下一个周期继续拉取 - EXECUTOR.schedule(this, period, TimeUnit.MICROSECONDS); + EXECUTOR.schedule(this, period, TimeUnit.MILLISECONDS); } else { // 数据没有消费完,直接开启下一个消费周期 EXECUTOR.execute(this);