diff --git a/LaunchServer/src/main/java/ru/gravit/launchserver/websocket/NettyIpForwardHandler.java b/LaunchServer/src/main/java/ru/gravit/launchserver/websocket/NettyIpForwardHandler.java index f0eb5331..ddec16f5 100644 --- a/LaunchServer/src/main/java/ru/gravit/launchserver/websocket/NettyIpForwardHandler.java +++ b/LaunchServer/src/main/java/ru/gravit/launchserver/websocket/NettyIpForwardHandler.java @@ -21,7 +21,7 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception //super.channelRead(ctx, msg); if(context.ip != null) { - ctx.write(msg); + ctx.writeAndFlush(msg); return; } if(msg instanceof HttpRequest) @@ -44,6 +44,6 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception else LogHelper.error("IpForwarding error. Headers not found"); } else LogHelper.error("IpForwarding error. Real message class %s", msg.getClass().getName()); - ctx.write(msg); + ctx.writeAndFlush(msg); } }