From 5bda3a25b04405ca8376676329e202eb7c51c788 Mon Sep 17 00:00:00 2001 From: Norman Maurer Date: Tue, 19 Feb 2013 19:08:04 +0100 Subject: [PATCH] add more debug info about discarded message --- .../main/java/io/netty/channel/DefaultChannelPipeline.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java index 13b7d18ede..9e3f34a0ba 100755 --- a/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java +++ b/transport/src/main/java/io/netty/channel/DefaultChannelPipeline.java @@ -1159,6 +1159,9 @@ final class DefaultChannelPipeline implements ChannelPipeline { if (m instanceof ReferenceCounted) { ((ReferenceCounted) m).release(); } + logger.debug( + "Discarded inbound message {} that reached at the end of the pipeline. " + + "Please check your pipeline configuration.", m); } logger.warn( "Discarded {} inbound message(s) that reached at the end of the pipeline. " + @@ -1295,6 +1298,9 @@ final class DefaultChannelPipeline implements ChannelPipeline { ByteBuf src = (ByteBuf) m; byteSink.writeBytes(src, src.readerIndex(), src.readableBytes()); } else { + logger.debug( + "Discarded outbound message {} that reached at the end of the pipeline. " + + "Please check your pipeline configuration.", m); discardedMessages ++; }