优化

2 years ago · 200f956a4f
1 changed files with 2 additions and 0 deletions
--- a/im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java
+++ b/im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java
@ -71,6 +71,8 @@ public class RedisMQPullTask implements CommandLineRunner {
                        }
                    } catch (Exception e) {
                        log.error("数据消费异常,队列:{}", queue, e);
+                        EXECUTOR_SERVICE.schedule(this, period, TimeUnit.MICROSECONDS);
+                        return;
                    }
                    // 继续消费数据
                    if (!EXECUTOR_SERVICE.isShutdown()) {