opensource/RuoYi-Vue-Plus
2
0
Fork 1
mirror of https://gitee.com/dromara/RuoYi-Vue-Plus.git synced 2026-09-20 18:15:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Pre Merge pull request !446 from vcoder/4.X

Browse Source
This commit is contained in:
vcoder 2023-11-10 06:38:31 +00:00 committed by Gitee
commit ba6c1b0c35
No known key found for this signature in database
GPG Key ID: 173E9B9CA92EEF8F
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java
View File

@ -227,6 +227,7 @@ public class QueueUtils {
public static <T> void subscribeBlockingQueue(String queueName, Consumer<T> consumer) { public static <T> void subscribeBlockingQueue(String queueName, Consumer<T> consumer) {
RBlockingQueue<T> queue = CLIENT.getBlockingQueue(queueName); RBlockingQueue<T> queue = CLIENT.getBlockingQueue(queueName);
queue.subscribeOnElements(consumer); queue.subscribeOnElements(consumer);
CLIENT.getDelayedQueue(queue);
} }
} }