From fe31d260c3e66f29bdbb4c726e7038b5167f8f27 Mon Sep 17 00:00:00 2001
From: lixinyang <1040862701@qq.com>
Date: Sat, 10 Aug 2024 07:04:14 +0800
Subject: [PATCH] =?UTF-8?q?fix(redis=20leftPop=E6=9C=89bug=E9=80=A0?=
 =?UTF-8?q?=E6=88=90=E6=B6=88=E6=81=AF=E4=B8=A2=E5=A4=B1):=20=E5=A1=AB?=
 =?UTF-8?q?=E8=A1=A5=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/bx/imcommon/mq/RedisMQPullTask.java      | 3 +++
 1 file changed, 3 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 29493ff..cd367c8 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
@@ -102,6 +102,9 @@ public class RedisMQPullTask implements CommandLineRunner {
                 objects.add(obj);
                 obj = redisMQTemplate.opsForList().leftPop(key);
             }
+            if (!Objects.isNull(obj)){
+                objects.add(obj);
+            }
         }
         return objects;
     }