I'm seeing hangs when I use an IoEventQueueThrottle as below. I read the
comments in the javadoc about requiring an executor in the filter chain.
I get no hangs if I do not add "writeThrottle" into the chain (my app
is currently throttling by waiting for every 100th write to complete).
// Setup
NioSocketConnector connector = new NioSocketConnector();
connector.getFilterChain().addFirst("executor", new ExecutorFilter(1));
connector.getFilterChain().addLast("writeThrottle",
new WriteRequestFilter(new IoEventQueueThrottle(10)));
// message sennding
IoBuffer buf = prepareBuffer();
WriteFuture wf = session.write(buf);
Are there any examples of how to use IoEventQueueThrottle for write
throttling?
Thanks,
Dan.