Recycle messagelist when channel goes inactive

This commit is contained in:
md_5 2013-07-10 09:18:58 +10:00
parent 0189ad9c17
commit daa58ffe58
2 changed files with 2 additions and 1 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;
private final MessageList<Object> queue = MessageList.newInstance(); 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,6 +56,7 @@ 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