diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java index c678ec9..22f07ee 100644 --- a/src/main/java/redis/clients/jedis/Protocol.java +++ b/src/main/java/redis/clients/jedis/Protocol.java @@ -91,8 +91,10 @@ public class Protocol { return processInteger(is); } else if (b == DOLLAR_BYTE) { return processBulkReply(is); - } else { + } else if (b == PLUS_BYTE) { return processStatusCodeReply(is); + } else { + throw new JedisException("Unknown reply"); } } catch (IOException e) { throw new JedisException(e);