@ -97,8 +97,7 @@ public class CommandData<T, R> implements QueueCommand {
}
public boolean isBlockingCommand() {
return RedisCommands.BLOCKING_COMMAND_NAMES.contains(command.getName())
|| RedisCommands.BLOCKING_COMMANDS.contains(command);
return command.isBlockingCommand();
@Override
@ -107,6 +107,11 @@ public class RedisCommand<R> {
return convertor;
return RedisCommands.BLOCKING_COMMAND_NAMES.contains(getName())
|| RedisCommands.BLOCKING_COMMANDS.contains(this);
public String toString() {
StringBuilder str = new StringBuilder();
str.append("(").append(name);