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; }