From 04d7eda278aef7d52fdb6c287d5a9ff2ce9881f4 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Sat, 22 Jun 2024 20:02:49 +0300 Subject: [PATCH] refactoring --- .../main/java/org/redisson/client/handler/CommandDecoder.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java b/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java index b66dbede3..ea1dea9e8 100644 --- a/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java +++ b/redisson/src/main/java/org/redisson/client/handler/CommandDecoder.java @@ -250,10 +250,6 @@ public class CommandDecoder extends ReplayingDecoder { } protected void sendNext(Channel channel) { - if (!(Thread.currentThread() instanceof FastThreadLocalThread)) { - return; - } - Queue queue = channel.attr(CommandsQueue.COMMANDS_QUEUE).get(); queue.poll(); state(null);