ASKING support #164

pull/115/merge
Nikita 10 years ago
parent 77b3e979e2
commit 1a7a8437cf

@ -72,6 +72,10 @@ public class Command<K, V, T> {
String[] parts = output.getError().split(" "); String[] parts = output.getError().split(" ");
int slot = Integer.valueOf(parts[1]); int slot = Integer.valueOf(parts[1]);
promise.setFailure(new RedisMovedException(slot)); 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 { } else {
promise.setFailure(new RedisException(output.getError())); promise.setFailure(new RedisException(output.getError()));
} }

Loading…
Cancel
Save