diff --git a/src/main/java/org/jboss/netty/handler/codec/frame/FrameDecoder.java b/src/main/java/org/jboss/netty/handler/codec/frame/FrameDecoder.java index b0a91c182c..a3e173d168 100644 --- a/src/main/java/org/jboss/netty/handler/codec/frame/FrameDecoder.java +++ b/src/main/java/org/jboss/netty/handler/codec/frame/FrameDecoder.java @@ -298,6 +298,10 @@ public abstract class FrameDecoder extends SimpleChannelUpstreamHandler { unfoldAndFireMessageReceived(context, remoteAddress, frame); } + + if (!cumulation.readable()) { + this.cumulation = null; + } } private void unfoldAndFireMessageReceived(ChannelHandlerContext context, SocketAddress remoteAddress, Object result) {