diff --git a/src/main/java/com/lambdaworks/redis/protocol/Command.java b/src/main/java/com/lambdaworks/redis/protocol/Command.java index e8dbac516..e0da32b21 100644 --- a/src/main/java/com/lambdaworks/redis/protocol/Command.java +++ b/src/main/java/com/lambdaworks/redis/protocol/Command.java @@ -72,6 +72,10 @@ public class Command { String[] parts = output.getError().split(" "); int slot = Integer.valueOf(parts[1]); promise.setFailure(new RedisMovedException(slot)); + } else if (output.getError().startsWith("(error) ASK")) { + String[] parts = output.getError().split(" "); + int slot = Integer.valueOf(parts[2]); + promise.setFailure(new RedisMovedException(slot)); } else { promise.setFailure(new RedisException(output.getError())); }