Package org.apache.mina.filter.executor
Class ExecutorFilter
java.lang.Object
org.apache.mina.common.IoFilterAdapter
org.apache.mina.filter.executor.ExecutorFilter
- All Implemented Interfaces:
IoFilter
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
Nested ClassesModifier and TypeClassDescriptionprotected static class
protected static class
Nested classes/interfaces inherited from interface org.apache.mina.common.IoFilter
IoFilter.NextFilter, IoFilter.WriteRequest
-
Constructor Summary
ConstructorsConstructorDescriptionCreates 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. -
Method Summary
Modifier and TypeMethodDescriptionvoid
exceptionCaught
(IoFilter.NextFilter nextFilter, IoSession session, Throwable cause) FiltersIoHandler.exceptionCaught(IoSession,Throwable)
event.void
filterClose
(IoFilter.NextFilter nextFilter, IoSession session) FiltersIoSession.close()
method invocation.void
filterWrite
(IoFilter.NextFilter nextFilter, IoSession session, IoFilter.WriteRequest writeRequest) FiltersIoSession.write(Object)
method invocation.Returns the underlyingExecutor
instance this filter uses.void
messageReceived
(IoFilter.NextFilter nextFilter, IoSession session, Object message) FiltersIoHandler.messageReceived(IoSession,Object)
event.void
messageSent
(IoFilter.NextFilter nextFilter, IoSession session, Object message) FiltersIoHandler.messageSent(IoSession,Object)
event.protected void
processEvent
(IoFilter.NextFilter nextFilter, IoSession session, ExecutorFilter.EventType type, Object data) void
sessionClosed
(IoFilter.NextFilter nextFilter, IoSession session) FiltersIoHandler.sessionClosed(IoSession)
event.void
sessionCreated
(IoFilter.NextFilter nextFilter, IoSession session) FiltersIoHandler.sessionCreated(IoSession)
event.void
sessionIdle
(IoFilter.NextFilter nextFilter, IoSession session, IdleStatus status) FiltersIoHandler.sessionIdle(IoSession,IdleStatus)
event.void
sessionOpened
(IoFilter.NextFilter nextFilter, IoSession session) FiltersIoHandler.sessionOpened(IoSession)
event.Methods inherited from class org.apache.mina.common.IoFilterAdapter
destroy, init, onPostAdd, onPostRemove, onPreAdd, onPreRemove
-
Constructor Details
-
ExecutorFilter
public ExecutorFilter()Creates a new instace with the default thread pool implementation (new ThreadPoolExecutor(16, 16, 60, TimeUnit.SECONDS, new LinkedBlockingQueue() )). -
ExecutorFilter
Creates a new instance with the specified executor.
-
-
Method Details
-
getExecutor
Returns the underlyingExecutor
instance this filter uses. -
sessionCreated
Description copied from interface:IoFilter
FiltersIoHandler.sessionCreated(IoSession)
event.- Specified by:
sessionCreated
in interfaceIoFilter
- Overrides:
sessionCreated
in classIoFilterAdapter
-
sessionOpened
Description copied from interface:IoFilter
FiltersIoHandler.sessionOpened(IoSession)
event.- Specified by:
sessionOpened
in interfaceIoFilter
- Overrides:
sessionOpened
in classIoFilterAdapter
-
sessionClosed
Description copied from interface:IoFilter
FiltersIoHandler.sessionClosed(IoSession)
event.- Specified by:
sessionClosed
in interfaceIoFilter
- Overrides:
sessionClosed
in classIoFilterAdapter
-
sessionIdle
Description copied from interface:IoFilter
FiltersIoHandler.sessionIdle(IoSession,IdleStatus)
event.- Specified by:
sessionIdle
in interfaceIoFilter
- Overrides:
sessionIdle
in classIoFilterAdapter
-
exceptionCaught
Description copied from interface:IoFilter
FiltersIoHandler.exceptionCaught(IoSession,Throwable)
event.- Specified by:
exceptionCaught
in interfaceIoFilter
- Overrides:
exceptionCaught
in classIoFilterAdapter
-
messageReceived
Description copied from interface:IoFilter
FiltersIoHandler.messageReceived(IoSession,Object)
event.- Specified by:
messageReceived
in interfaceIoFilter
- Overrides:
messageReceived
in classIoFilterAdapter
-
messageSent
Description copied from interface:IoFilter
FiltersIoHandler.messageSent(IoSession,Object)
event.- Specified by:
messageSent
in interfaceIoFilter
- Overrides:
messageSent
in classIoFilterAdapter
-
processEvent
protected void processEvent(IoFilter.NextFilter nextFilter, IoSession session, ExecutorFilter.EventType type, Object data) -
filterWrite
public void filterWrite(IoFilter.NextFilter nextFilter, IoSession session, IoFilter.WriteRequest writeRequest) Description copied from interface:IoFilter
FiltersIoSession.write(Object)
method invocation.- Specified by:
filterWrite
in interfaceIoFilter
- Overrides:
filterWrite
in classIoFilterAdapter
-
filterClose
Description copied from interface:IoFilter
FiltersIoSession.close()
method invocation.- Specified by:
filterClose
in interfaceIoFilter
- Overrides:
filterClose
in classIoFilterAdapter
- Throws:
Exception
-