diff --git a/src/main/java/com/corundumstudio/socketio/transport/FlashPolicyHandler.java b/src/main/java/com/corundumstudio/socketio/transport/FlashPolicyHandler.java index 15f1784..80a817e 100644 --- a/src/main/java/com/corundumstudio/socketio/transport/FlashPolicyHandler.java +++ b/src/main/java/com/corundumstudio/socketio/transport/FlashPolicyHandler.java @@ -27,16 +27,15 @@ import io.netty.util.CharsetUtil; @Sharable public class FlashPolicyHandler extends ChannelInboundHandlerAdapter { - private final ByteBuf requestBuffer = Unpooled.unreleasableBuffer(Unpooled.copiedBuffer( - "", CharsetUtil.UTF_8)); + private final ByteBuf requestBuffer = Unpooled.copiedBuffer( "", CharsetUtil.UTF_8); - private final ByteBuf responseBuffer = Unpooled.unreleasableBuffer(Unpooled.copiedBuffer( + private final ByteBuf responseBuffer = Unpooled.copiedBuffer( "" + "" + " " + " " + " " - + "", CharsetUtil.UTF_8)); + + "", CharsetUtil.UTF_8); @Override public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception { @@ -45,7 +44,7 @@ public class FlashPolicyHandler extends ChannelInboundHandlerAdapter { ByteBuf data = message.slice(0, requestBuffer.readableBytes()); if (data.equals(requestBuffer)) { message.release(); - ChannelFuture f = ctx.writeAndFlush(responseBuffer); + ChannelFuture f = ctx.writeAndFlush(Unpooled.copiedBuffer(responseBuffer)); f.addListener(ChannelFutureListener.CLOSE); return; }