@ -141,11 +141,6 @@ public class RedisConnection implements RedisCommands {
return null;
}
public void clearCurrentCommand() {
Queue<QueueCommandHolder> queue = channel.attr(CommandsQueue.COMMANDS_QUEUE).get();
queue.poll();
public CommandData<?, ?> getCurrentCommand() {
if (queue != null) {