|
|
@ -52,11 +52,7 @@ public class CommandsQueue extends ChannelDuplexHandler {
|
|
|
|
Iterator<QueueCommandHolder> iterator = queue.iterator();
|
|
|
|
Iterator<QueueCommandHolder> iterator = queue.iterator();
|
|
|
|
while (iterator.hasNext()) {
|
|
|
|
while (iterator.hasNext()) {
|
|
|
|
QueueCommandHolder command = iterator.next();
|
|
|
|
QueueCommandHolder command = iterator.next();
|
|
|
|
|
|
|
|
if (command.getCommand().isBlockingCommand()) {
|
|
|
|
CommandData cc = (CommandData) command.getCommand();
|
|
|
|
|
|
|
|
RedisCommand cmd = cc.getCommand();
|
|
|
|
|
|
|
|
if (RedisCommands.BLOCKING_COMMAND_NAMES.contains(cmd.getName())
|
|
|
|
|
|
|
|
|| RedisCommands.BLOCKING_COMMANDS.contains(cmd)) {
|
|
|
|
|
|
|
|
continue;
|
|
|
|
continue;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|