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.

Reply via email to