监听消息后先获取一下队列，防止服务重启后没有入队列的数据时之前的消息卡住

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