From 509646b0700f0d36edda7abe8328171ce3f424b4 Mon Sep 17 00:00:00 2001
From: seakider <seakider@gmail.com>
Date: Tue, 4 Mar 2025 22:18:36 +0800
Subject: [PATCH] Fixed - RDelayedQueue cannot get anything when server run a
 long time

Signed-off-by: seakider <seakider@gmail.com>
---
 redisson/src/main/java/org/redisson/QueueTransferTask.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/QueueTransferTask.java b/redisson/src/main/java/org/redisson/QueueTransferTask.java
index 2dd7e5df2..de3a41eae 100644
--- a/redisson/src/main/java/org/redisson/QueueTransferTask.java
+++ b/redisson/src/main/java/org/redisson/QueueTransferTask.java
@@ -133,9 +133,8 @@ public abstract class QueueTransferTask {
                     }
                 }
             }, delay, TimeUnit.MILLISECONDS);
-            if (!lastTimeout.compareAndSet(oldTimeout, new TimeoutTask(startTime, timeout))) {
-                timeout.cancel();
-            }
+            
+            lastTimeout.compareAndSet(oldTimeout, new TimeoutTask(startTime, timeout));
         } else {
             pushTask();
         }