diff --git a/example/src/main/java/io/netty/example/socksproxy/SocksServerHandler.java b/example/src/main/java/io/netty/example/socksproxy/SocksServerHandler.java index 3f144de079..fdba9226d0 100644 --- a/example/src/main/java/io/netty/example/socksproxy/SocksServerHandler.java +++ b/example/src/main/java/io/netty/example/socksproxy/SocksServerHandler.java @@ -57,6 +57,7 @@ public final class SocksServerHandler extends ChannelInboundMessageHandlerAdapte ctx.pipeline().addLast(SocksServerConnectHandler.getName(), new SocksServerConnectHandler()); ctx.pipeline().remove(this); ctx.nextInboundMessageBuffer().add(socksRequest); + ctx.fireInboundBufferUpdated(); } else { ctx.close(); }