org.jivesoftware.openfire.net

Class StalledSessionsFilter

java.lang.Object

org.apache.mina.core.filterchain.IoFilterAdapter

org.jivesoftware.openfire.net.StalledSessionsFilter

All Implemented Interfaces:

org.apache.mina.core.filterchain.IoFilter

public class StalledSessionsFilter
extends org.apache.mina.core.filterchain.IoFilterAdapter

MINA filter that will close sessions that are failing to read outgoing traffic and whose outgoing queue is around 5MB. Use the system property session.stalled.cap to set the max number of bytes allowed in the outgoing queue of a session before considering it stalled.

Author:

Gaston Dombiak

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.mina.core.filterchain.IoFilter

org.apache.mina.core.filterchain.IoFilter.NextFilter

Constructor Summary

Constructors

Constructor and Description
StalledSessionsFilter()

Method Summary

Modifier and Type	Method and Description
void	filterWrite(org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter, org.apache.mina.core.session.IoSession session, org.apache.mina.core.write.WriteRequest writeRequest)

Methods inherited from class org.apache.mina.core.filterchain.IoFilterAdapter

destroy, exceptionCaught, filterClose, init, messageReceived, messageSent, onPostAdd, onPostRemove, onPreAdd, onPreRemove, sessionClosed, sessionCreated, sessionIdle, sessionOpened, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

StalledSessionsFilter

public StalledSessionsFilter()

Method Detail

filterWrite

public void filterWrite(org.apache.mina.core.filterchain.IoFilter.NextFilter nextFilter,
                        org.apache.mina.core.session.IoSession session,
                        org.apache.mina.core.write.WriteRequest writeRequest)
                 throws Exception

Specified by:

filterWrite in interface org.apache.mina.core.filterchain.IoFilter

Overrides:

filterWrite in class org.apache.mina.core.filterchain.IoFilterAdapter

Throws:

Exception