|
|
|
@ -22,11 +22,11 @@ import java.util.regex.Pattern;
|
|
|
|
|
|
|
|
|
|
import org.redisson.client.ChannelName;
|
|
|
|
|
import org.redisson.client.RedisConnectionClosedException;
|
|
|
|
|
import org.redisson.client.RedisConnectionException;
|
|
|
|
|
import org.redisson.client.WriteRedisConnectionException;
|
|
|
|
|
import org.redisson.client.protocol.CommandData;
|
|
|
|
|
import org.redisson.client.protocol.QueueCommand;
|
|
|
|
|
import org.redisson.client.protocol.QueueCommandHolder;
|
|
|
|
|
import org.redisson.misc.LogHelper;
|
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
|
|
|
|
|
@ -80,10 +80,12 @@ public class CommandsQueue extends ChannelDuplexHandler {
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
command.getChannelPromise().tryFailure(
|
|
|
|
|
new WriteRedisConnectionException("Channel has been closed! Can't write command: " + command.getCommand() + " to channel: " + ctx.channel()));
|
|
|
|
|
new WriteRedisConnectionException("Channel has been closed! Can't write command: "
|
|
|
|
|
+ LogHelper.toString(command.getCommand()) + " to channel: " + ctx.channel()));
|
|
|
|
|
|
|
|
|
|
if (command.getChannelPromise().isSuccess()) {
|
|
|
|
|
command.getCommand().tryFailure(new RedisConnectionClosedException("Command succesfully sent, but channel " + ctx.channel() + " has been closed!"));
|
|
|
|
|
command.getCommand().tryFailure(new RedisConnectionClosedException("Command "
|
|
|
|
|
+ LogHelper.toString(command.getCommand()) + " succesfully sent, but channel " + ctx.channel() + " has been closed!"));
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|