From 1a7a8437cf5448c7ce2c5d7c71a120e30bacc60d Mon Sep 17 00:00:00 2001 From: Nikita Date: Tue, 9 Jun 2015 11:24:08 +0300 Subject: [PATCH] ASKING support #164 --- src/main/java/com/lambdaworks/redis/protocol/Command.java | 4 ++++ 1 file changed, 4 insertions(+) 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())); }