From 5911e94b65e45c98c81f64928232b5d8f824a19b Mon Sep 17 00:00:00 2001 From: 疯狂的狮子Li <15040126243@163.com> Date: 星期六, 14 一月 2023 01:01:13 +0800 Subject: [PATCH] update 优化 利用 resultMap 自动映射配置 简化 xml (非嵌套) --- ruoyi-common/src/main/java/com/ruoyi/common/utils/redis/QueueUtils.java | 16 ---------------- 1 files changed, 0 insertions(+), 16 deletions(-) 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 b8fa308..7a4bce4 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 @@ -5,7 +5,6 @@ import lombok.NoArgsConstructor; import org.redisson.api.*; -import java.util.Comparator; import java.util.concurrent.TimeUnit; import java.util.function.Consumer; @@ -119,21 +118,6 @@ RBlockingQueue<T> queue = CLIENT.getBlockingQueue(queueName); RDelayedQueue<T> delayedQueue = CLIENT.getDelayedQueue(queue); delayedQueue.destroy(); - } - - /** - * 灏濊瘯璁剧疆 浼樺厛闃熷垪姣旇緝鍣� 鐢ㄤ簬鎺掑簭浼樺厛绾� - * - * @param queueName 闃熷垪鍚� - * @param comparator 姣旇緝鍣� - * @param destroy 宸插瓨鍦ㄦ槸鍚﹂攢姣� - */ - public static <T> boolean trySetPriorityQueueComparator(String queueName, Comparator<T> comparator, boolean destroy) { - RPriorityBlockingQueue<T> priorityBlockingQueue = CLIENT.getPriorityBlockingQueue(queueName); - if (priorityBlockingQueue.isExists() && destroy) { - destroyQueue(queueName); - } - return priorityBlockingQueue.trySetComparator(comparator); } /** -- Gitblit v1.9.3