Browse Source

fix(延时线程池调度方法参数错误): 将微妙换成秒

master
lixinyang 2 years ago
parent
commit
8023121d15
  1. 2
      im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java

2
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);

Loading…
Cancel
Save