public class ProtocolThreadPoolFilter extends BaseThreadPool implements ThreadPool, ProtocolFilter
ProtocolHandler
events
to its thread pool.ThreadPool
,
BaseThreadPool
BaseThreadPool.SessionBuffer
ProtocolFilter.NextFilter
DEFAULT_KEEP_ALIVE_TIME, DEFAULT_MAXIMUM_POOL_SIZE
Constructor and Description |
---|
ProtocolThreadPoolFilter()
Creates a new instanceof this filter with default thread pool settings.
|
ProtocolThreadPoolFilter(java.lang.String threadNamePrefix)
Creates a new instance of this filter with default thread pool settings.
|
fetchSessionBuffer, fireEvent, getKeepAliveTime, getMaximumPoolSize, getPoolSize, getThreadNamePrefix, setKeepAliveTime, setMaximumPoolSize, start, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getKeepAliveTime, getMaximumPoolSize, getPoolSize, setKeepAliveTime, setMaximumPoolSize, start, stop
public ProtocolThreadPoolFilter()
BaseThreadPool.start()
method to start threads actually.public ProtocolThreadPoolFilter(java.lang.String threadNamePrefix)
BaseThreadPool.start()
method to start threads actually.threadNamePrefix
- the prefix of the thread names this pool will create.public void sessionOpened(ProtocolFilter.NextFilter nextFilter, ProtocolSession session)
ProtocolFilter
ProtocolHandler.sessionOpened(ProtocolSession)
event.sessionOpened
in interface ProtocolFilter
public void sessionClosed(ProtocolFilter.NextFilter nextFilter, ProtocolSession session)
ProtocolFilter
ProtocolHandler.sessionClosed(ProtocolSession)
event.sessionClosed
in interface ProtocolFilter
public void sessionIdle(ProtocolFilter.NextFilter nextFilter, ProtocolSession session, IdleStatus status)
ProtocolFilter
ProtocolHandler.sessionIdle(ProtocolSession,IdleStatus)
event.sessionIdle
in interface ProtocolFilter
public void exceptionCaught(ProtocolFilter.NextFilter nextFilter, ProtocolSession session, java.lang.Throwable cause)
ProtocolFilter
ProtocolHandler.exceptionCaught(ProtocolSession,Throwable)
event.exceptionCaught
in interface ProtocolFilter
public void messageReceived(ProtocolFilter.NextFilter nextFilter, ProtocolSession session, java.lang.Object message)
ProtocolFilter
ProtocolHandler.messageReceived(ProtocolSession,Object)
event.messageReceived
in interface ProtocolFilter
public void messageSent(ProtocolFilter.NextFilter nextFilter, ProtocolSession session, java.lang.Object message)
ProtocolFilter
ProtocolHandler.messageSent(ProtocolSession,Object)
event.messageSent
in interface ProtocolFilter
protected void processEvent(java.lang.Object nextFilter0, Session session0, EventType type, java.lang.Object data)
BaseThreadPool
processEvent
in class BaseThreadPool
public void filterWrite(ProtocolFilter.NextFilter nextFilter, ProtocolSession session, java.lang.Object message)
ProtocolFilter
ProtocolSession.write(Object)
method invocation.filterWrite
in interface ProtocolFilter