Recycle messagelist when channel goes inactive (reverted from commit daa58ffe58)

This commit is contained in:
md_5 2013-07-10 23:41:37 +10:00
parent 8c2bea5be2
commit 55a6cc56ef
2 changed files with 1 additions and 2 deletions

View File

@ -15,7 +15,7 @@ public class ChannelWrapper
private final Channel ch; private final Channel ch;
@Getter @Getter
private volatile boolean closed; private volatile boolean closed;
final MessageList<Object> queue = MessageList.newInstance(); private final MessageList<Object> queue = MessageList.newInstance();
private volatile boolean flushNow = true; private volatile boolean flushNow = true;
public ChannelWrapper(ChannelHandlerContext ctx) public ChannelWrapper(ChannelHandlerContext ctx)

View File

@ -56,7 +56,6 @@ public class HandlerBoss extends ChannelInboundHandlerAdapter
ProxyServer.getInstance().getLogger().log( Level.INFO, "{0} has disconnected", handler ); ProxyServer.getInstance().getLogger().log( Level.INFO, "{0} has disconnected", handler );
} }
} }
channel.queue.recycle();
} }
@Override @Override