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);