Description
If you look into ConnectionThrottleFilter.sessionCreated():
@Override
public void sessionCreated(NextFilter nextFilter, IoSession session)
throws Exception {
if (!isConnectionOk(session))
}
ConnectionThrottleFilter doesn't forward sessionCreated event to the next filter. It should look like the following:
@Override
public void sessionCreated(NextFilter nextFilter, IoSession session)
throws Exception {
if (!isConnectionOk(session)) { logger.warn("Connections coming in too fast; closing."); session.close(); }
nextFilter.sessionCreated(session);
}