|
||||||||||
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
.
This filter is usually inserted by ThreadModel
automatically, so you don't need
to add this filter in most cases.
Please note that this filter doesn't manage the life cycle of the underlying
Executor
. You have to destroy or stop it by yourself.
Apache Directory Project
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(edu.emory.mathcs.backport.java.util.concurrent.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(edu.emory.mathcs.backport.java.util.concurrent.Executor executor)
Method Detail |
---|
public edu.emory.mathcs.backport.java.util.concurrent.Executor getExecutor()
Executor
instance this filter uses.
public void sessionCreated(IoFilter.NextFilter nextFilter, IoSession session)
IoFilter
IoHandler.sessionCreated(IoSession)
event.
sessionCreated
in interface IoFilter
sessionCreated
in class IoFilterAdapter
public void sessionOpened(IoFilter.NextFilter nextFilter, IoSession session)
IoFilter
IoHandler.sessionOpened(IoSession)
event.
sessionOpened
in interface IoFilter
sessionOpened
in class IoFilterAdapter
public void sessionClosed(IoFilter.NextFilter nextFilter, IoSession session)
IoFilter
IoHandler.sessionClosed(IoSession)
event.
sessionClosed
in interface IoFilter
sessionClosed
in class IoFilterAdapter
public void sessionIdle(IoFilter.NextFilter nextFilter, IoSession session, IdleStatus status)
IoFilter
IoHandler.sessionIdle(IoSession,IdleStatus)
event.
sessionIdle
in interface IoFilter
sessionIdle
in class IoFilterAdapter
public void exceptionCaught(IoFilter.NextFilter nextFilter, IoSession session, Throwable cause)
IoFilter
IoHandler.exceptionCaught(IoSession,Throwable)
event.
exceptionCaught
in interface IoFilter
exceptionCaught
in class IoFilterAdapter
public void messageReceived(IoFilter.NextFilter nextFilter, IoSession session, Object message)
IoFilter
IoHandler.messageReceived(IoSession,Object)
event.
messageReceived
in interface IoFilter
messageReceived
in class IoFilterAdapter
public void messageSent(IoFilter.NextFilter nextFilter, IoSession session, Object message)
IoFilter
IoHandler.messageSent(IoSession,Object)
event.
messageSent
in interface IoFilter
messageSent
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)
IoFilter
IoSession.write(Object)
method invocation.
filterWrite
in interface IoFilter
filterWrite
in class IoFilterAdapter
public void filterClose(IoFilter.NextFilter nextFilter, IoSession session) throws Exception
IoFilter
IoSession.close()
method invocation.
filterClose
in interface IoFilter
filterClose
in class IoFilterAdapter
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |