|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.mina.common.IoFilterAdapter
org.apache.mina.filter.executor.ExecutorFilter
public class ExecutorFilter
A filter that forward events to Executor in
backport-util-concurrent.
You can apply various thread model by inserting this filter to the IoFilterChain.
Please note that this filter doesn't manage the life cycle of the underlying
Executor. You have to destroy or stop it by yourself.
| Nested Class Summary | |
|---|---|
protected static class |
ExecutorFilter.Event
|
protected static class |
ExecutorFilter.EventType
|
| Nested classes/interfaces inherited from interface org.apache.mina.common.IoFilter |
|---|
IoFilter.NextFilter, IoFilter.WriteRequest |
| Constructor Summary | |
|---|---|
ExecutorFilter()
Creates a new instace with the default thread pool implementation (new ThreadPoolExecutor(16, 16, 60, TimeUnit.SECONDS, new LinkedBlockingQueue() )). |
|
ExecutorFilter(Executor executor)
Creates a new instance with the specified executor. |
|
| Methods inherited from class org.apache.mina.common.IoFilterAdapter |
|---|
destroy, init, onPostAdd, onPostRemove, onPreAdd, onPreRemove |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public ExecutorFilter()
public ExecutorFilter(Executor executor)
| Method Detail |
|---|
public Executor getExecutor()
Executor instance this filter uses.
public void sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
IoFilterIoHandler.sessionCreated(IoSession) event.
sessionCreated in interface IoFiltersessionCreated in class IoFilterAdapter
public void sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
IoFilterIoHandler.sessionOpened(IoSession) event.
sessionOpened in interface IoFiltersessionOpened in class IoFilterAdapter
public void sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
IoFilterIoHandler.sessionClosed(IoSession) event.
sessionClosed in interface IoFiltersessionClosed in class IoFilterAdapter
public void sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
IoFilterIoHandler.sessionIdle(IoSession,IdleStatus)
event.
sessionIdle in interface IoFiltersessionIdle in class IoFilterAdapter
public void exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
IoFilterIoHandler.exceptionCaught(IoSession,Throwable)
event.
exceptionCaught in interface IoFilterexceptionCaught in class IoFilterAdapter
public void messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
IoFilterIoHandler.messageReceived(IoSession,Object)
event.
messageReceived in interface IoFiltermessageReceived in class IoFilterAdapter
public void messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
IoFilterIoHandler.messageSent(IoSession,Object)
event.
messageSent in interface IoFiltermessageSent in class IoFilterAdapter
protected void processEvent(IoFilter.NextFilter nextFilter,
IoSession session,
ExecutorFilter.EventType type,
Object data)
public void filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest)
IoFilterIoSession.write(Object) method invocation.
filterWrite in interface IoFilterfilterWrite in class IoFilterAdapter
public void filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
throws Exception
IoFilterIoSession.close() method invocation.
filterClose in interface IoFilterfilterClose in class IoFilterAdapterException
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||