From 3471045235df045d8b36a303d2715da38a9eca93 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Tue, 17 Sep 2024 12:47:21 +0300 Subject: [PATCH] refactoring --- redisson/src/main/java/org/redisson/QueueTransferTask.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/QueueTransferTask.java b/redisson/src/main/java/org/redisson/QueueTransferTask.java index 8c4d57904..59334f40b 100644 --- a/redisson/src/main/java/org/redisson/QueueTransferTask.java +++ b/redisson/src/main/java/org/redisson/QueueTransferTask.java @@ -98,8 +98,7 @@ public abstract class QueueTransferTask { public void stop() { RTopic schedulerTopic = getTopic(); - schedulerTopic.removeListener(messageListenerId); - schedulerTopic.removeListener(statusListenerId); + schedulerTopic.removeListenerAsync(messageListenerId, statusListenerId); } private void scheduleTask(final Long startTime) {