From ddd5bf40c901052271d9dd127b003cc2e89c9fd1 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Wed, 29 Sep 2021 11:27:56 +0300 Subject: [PATCH] refactoring --- .../main/java/org/redisson/client/protocol/CommandData.java | 3 +-- .../main/java/org/redisson/client/protocol/RedisCommand.java | 5 +++++ 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/client/protocol/CommandData.java b/redisson/src/main/java/org/redisson/client/protocol/CommandData.java index 18c6aca42..166a24f81 100644 --- a/redisson/src/main/java/org/redisson/client/protocol/CommandData.java +++ b/redisson/src/main/java/org/redisson/client/protocol/CommandData.java @@ -97,8 +97,7 @@ public class CommandData implements QueueCommand { } public boolean isBlockingCommand() { - return RedisCommands.BLOCKING_COMMAND_NAMES.contains(command.getName()) - || RedisCommands.BLOCKING_COMMANDS.contains(command); + return command.isBlockingCommand(); } @Override diff --git a/redisson/src/main/java/org/redisson/client/protocol/RedisCommand.java b/redisson/src/main/java/org/redisson/client/protocol/RedisCommand.java index 86cca0d56..1dab9153d 100644 --- a/redisson/src/main/java/org/redisson/client/protocol/RedisCommand.java +++ b/redisson/src/main/java/org/redisson/client/protocol/RedisCommand.java @@ -107,6 +107,11 @@ public class RedisCommand { return convertor; } + public boolean isBlockingCommand() { + return RedisCommands.BLOCKING_COMMAND_NAMES.contains(getName()) + || RedisCommands.BLOCKING_COMMANDS.contains(this); + } + public String toString() { StringBuilder str = new StringBuilder(); str.append("(").append(name);