add fireInboundBufferUpdated to fix #1085 socksproxy example

This commit is contained in:
alexey 2013-02-25 21:29:08 +04:00 committed by Norman Maurer
parent a75d42060a
commit 4d969b964f

View File

@ -57,6 +57,7 @@ public final class SocksServerHandler extends ChannelInboundMessageHandlerAdapte
ctx.pipeline().addLast(SocksServerConnectHandler.getName(), new SocksServerConnectHandler()); ctx.pipeline().addLast(SocksServerConnectHandler.getName(), new SocksServerConnectHandler());
ctx.pipeline().remove(this); ctx.pipeline().remove(this);
ctx.nextInboundMessageBuffer().add(socksRequest); ctx.nextInboundMessageBuffer().add(socksRequest);
ctx.fireInboundBufferUpdated();
} else { } else {
ctx.close(); ctx.close();
} }