Fix memory leak issue #21

redis · Jan 11, 2015 · bf620c6 · bf620c6
1 parent 82a62da
commit bf620c6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/com/lambdaworks/redis/pubsub/PubSubCommandHandler.java b/src/main/java/com/lambdaworks/redis/pubsub/PubSubCommandHandler.java
@@ -46,6 +46,7 @@ protected void decode(ChannelHandlerContext ctx, ByteBuf buffer) throws Interrup
                 return;
             }
             queue.take().complete();
+            buffer.discardReadBytes();
             if (output instanceof PubSubOutput) {
                 ctx.fireChannelRead(output);
             }