diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/HttpRequestEncoder.java b/codec-http/src/main/java/io/netty/handler/codec/http/HttpRequestEncoder.java index 4e7e2bf0a6..b1e1df22ce 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/HttpRequestEncoder.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/HttpRequestEncoder.java @@ -28,7 +28,7 @@ public class HttpRequestEncoder extends HttpObjectEncoder { private static final char SLASH = '/'; @Override - public boolean acceptOutboundMessage(Object msg) throws Exception { + protected boolean acceptOutboundMessage(Object msg) throws Exception { return super.acceptOutboundMessage(msg) && !(msg instanceof HttpResponse); } diff --git a/codec-http/src/main/java/io/netty/handler/codec/http/HttpResponseEncoder.java b/codec-http/src/main/java/io/netty/handler/codec/http/HttpResponseEncoder.java index 9d953900d0..7b30d0000d 100644 --- a/codec-http/src/main/java/io/netty/handler/codec/http/HttpResponseEncoder.java +++ b/codec-http/src/main/java/io/netty/handler/codec/http/HttpResponseEncoder.java @@ -27,7 +27,7 @@ import static io.netty.handler.codec.http.HttpConstants.*; public class HttpResponseEncoder extends HttpObjectEncoder { @Override - public boolean acceptOutboundMessage(Object msg) throws Exception { + protected boolean acceptOutboundMessage(Object msg) throws Exception { return super.acceptOutboundMessage(msg) && !(msg instanceof HttpRequest); } diff --git a/transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandlerAdapter.java b/transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandlerAdapter.java index 678593c032..c75a2d0889 100644 --- a/transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandlerAdapter.java +++ b/transport/src/main/java/io/netty/channel/ChannelOutboundMessageHandlerAdapter.java @@ -72,7 +72,7 @@ public abstract class ChannelOutboundMessageHandlerAdapter * * @param msg the message */ - public boolean acceptOutboundMessage(Object msg) throws Exception { + protected boolean acceptOutboundMessage(Object msg) throws Exception { return msgMatcher.match(msg); }