org.apache.mina.protocol.filter
Class ProtocolThreadPoolFilter
java.lang.Object
org.apache.mina.util.BaseThreadPool
org.apache.mina.protocol.filter.ProtocolThreadPoolFilter
- All Implemented Interfaces:
- ProtocolFilter, ThreadPool
public class ProtocolThreadPoolFilter
- extends BaseThreadPool
- implements ThreadPool, ProtocolFilter
A Thread-pooling filter. This filter forwards ProtocolHandler
events
to its thread pool.
- Version:
- $Rev: 210062 $, $Date: 2005-07-11 12:52:38 +0900 $
- Author:
- Trustin Lee (trustin@apache.org)
- See Also:
ThreadPool
,
BaseThreadPool
Method Summary |
void |
exceptionCaught(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Throwable cause)
Filters ProtocolHandler.exceptionCaught(ProtocolSession,Throwable)
event. |
void |
filterWrite(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Object message)
Filters ProtocolSession.write(Object) method invocation. |
void |
messageReceived(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Object message)
Filters ProtocolHandler.messageReceived(ProtocolSession,Object)
event. |
void |
messageSent(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Object message)
Filters ProtocolHandler.messageSent(ProtocolSession,Object)
event. |
protected void |
processEvent(Object nextFilter0,
Session session0,
EventType type,
Object data)
Implement this method to forward events to nextFilter. |
void |
sessionClosed(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session)
Filters ProtocolHandler.sessionClosed(ProtocolSession) event. |
void |
sessionIdle(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
IdleStatus status)
Filters ProtocolHandler.sessionIdle(ProtocolSession,IdleStatus)
event. |
void |
sessionOpened(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session)
Filters ProtocolHandler.sessionOpened(ProtocolSession) event. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ProtocolThreadPoolFilter
public ProtocolThreadPoolFilter()
- Creates a new instanceof this filter with default thread pool settings.
You'll have to invoke
BaseThreadPool.start()
method to start threads actually.
sessionOpened
public void sessionOpened(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session)
- Description copied from interface:
ProtocolFilter
- Filters
ProtocolHandler.sessionOpened(ProtocolSession)
event.
- Specified by:
sessionOpened
in interface ProtocolFilter
sessionClosed
public void sessionClosed(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session)
- Description copied from interface:
ProtocolFilter
- Filters
ProtocolHandler.sessionClosed(ProtocolSession)
event.
- Specified by:
sessionClosed
in interface ProtocolFilter
sessionIdle
public void sessionIdle(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
IdleStatus status)
- Description copied from interface:
ProtocolFilter
- Filters
ProtocolHandler.sessionIdle(ProtocolSession,IdleStatus)
event.
- Specified by:
sessionIdle
in interface ProtocolFilter
exceptionCaught
public void exceptionCaught(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Throwable cause)
- Description copied from interface:
ProtocolFilter
- Filters
ProtocolHandler.exceptionCaught(ProtocolSession,Throwable)
event.
- Specified by:
exceptionCaught
in interface ProtocolFilter
messageReceived
public void messageReceived(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Object message)
- Description copied from interface:
ProtocolFilter
- Filters
ProtocolHandler.messageReceived(ProtocolSession,Object)
event.
- Specified by:
messageReceived
in interface ProtocolFilter
messageSent
public void messageSent(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Object message)
- Description copied from interface:
ProtocolFilter
- Filters
ProtocolHandler.messageSent(ProtocolSession,Object)
event.
- Specified by:
messageSent
in interface ProtocolFilter
processEvent
protected void processEvent(Object nextFilter0,
Session session0,
EventType type,
Object data)
- Description copied from class:
BaseThreadPool
- Implement this method to forward events to nextFilter.
- Specified by:
processEvent
in class BaseThreadPool
filterWrite
public void filterWrite(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
Object message)
- Description copied from interface:
ProtocolFilter
- Filters
ProtocolSession.write(Object)
method invocation.
- Specified by:
filterWrite
in interface ProtocolFilter
Copyright © 2004-2005 . All Rights Reserved.