fix bug in pub/sub protocol decoding

wg · Mar 2, 2013 · 760f083 · 760f083
1 parent 9a03a78
commit 760f083
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/lambdaworks/redis/pubsub/PubSubCommandHandler.java b/src/main/java/com/lambdaworks/redis/pubsub/PubSubCommandHandler.java
@@ -36,7 +36,7 @@ public PubSubCommandHandler(BlockingQueue<Command<K, V, ?>> queue, RedisCodec<K,
 
     @Override
     protected void decode(ChannelHandlerContext ctx, ChannelBuffer buffer) throws InterruptedException {
-        while (!queue.isEmpty()) {
+        while (output.type() == null && !queue.isEmpty()) {
             CommandOutput<K, V, ?> output = queue.peek().getOutput();
             if (!rsm.decode(buffer, output)) return;
             queue.take().complete();