diff --git a/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java b/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java
index 842e4565b..537f82e02 100644
--- a/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java
+++ b/ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java
@@ -227,6 +227,7 @@ public class QueueUtils {
     public static <T> void subscribeBlockingQueue(String queueName, Consumer<T> consumer) {
         RBlockingQueue<T> queue = CLIENT.getBlockingQueue(queueName);
         queue.subscribeOnElements(consumer);
+        CLIENT.getDelayedQueue(queue);
     }
 
 }