@ -139,9 +139,13 @@ public class CommandDecoder extends ReplayingDecoder<State> {
cmd.getPromise().tryFailure(e);
}
if (!cmd.getPromise().isSuccess()) {
if (!(cmd.getPromise().cause() instanceof RedisMovedException
|| cmd.getPromise().cause() instanceof RedisAskException
|| cmd.getPromise().cause() instanceof RedisLoadingException)) {
error = (RedisException) cmd.getPromise().cause();
if (i == commands.getCommands().size()) {
Promise<Void> promise = commands.getPromise();