From 200f956a4fc1803215dea0a220d240f2b723f376 Mon Sep 17 00:00:00 2001
From: xsx <825657193@qq.com>
Date: Sat, 3 Aug 2024 11:49:10 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 im-commom/src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java | 2 ++
 1 file changed, 2 insertions(+)

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 45b73b7..feff73e 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
@@ -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()) {