diff --git a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java index 74ac909e..ca1a78da 100644 --- a/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java +++ b/proxy/src/main/java/net/md_5/bungee/netty/ChannelWrapper.java @@ -15,7 +15,7 @@ public class ChannelWrapper private final Channel ch; @Getter private volatile boolean closed; - final MessageList queue = MessageList.newInstance(); + private final MessageList queue = MessageList.newInstance(); private volatile boolean flushNow = true; public ChannelWrapper(ChannelHandlerContext ctx) diff --git a/proxy/src/main/java/net/md_5/bungee/netty/HandlerBoss.java b/proxy/src/main/java/net/md_5/bungee/netty/HandlerBoss.java index f784ad5c..ede4ad5c 100644 --- a/proxy/src/main/java/net/md_5/bungee/netty/HandlerBoss.java +++ b/proxy/src/main/java/net/md_5/bungee/netty/HandlerBoss.java @@ -56,7 +56,6 @@ public class HandlerBoss extends ChannelInboundHandlerAdapter ProxyServer.getInstance().getLogger().log( Level.INFO, "{0} has disconnected", handler ); } } - channel.queue.recycle(); } @Override