public class ExecutorFilter extends IoFilterAdapter
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
Modifier and Type | Class and Description |
---|---|
protected static class |
ExecutorFilter.Event |
protected static class |
ExecutorFilter.EventType |
IoFilter.NextFilter, IoFilter.WriteRequest
Constructor and Description |
---|
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.
|
destroy, init, onPostAdd, onPostRemove, onPreAdd, onPreRemove
public ExecutorFilter()
public ExecutorFilter(edu.emory.mathcs.backport.java.util.concurrent.Executor executor)
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, java.lang.Throwable cause)
IoFilter
IoHandler.exceptionCaught(IoSession,Throwable)
event.exceptionCaught
in interface IoFilter
exceptionCaught
in class IoFilterAdapter
public void messageReceived(IoFilter.NextFilter nextFilter, IoSession session, java.lang.Object message)
IoFilter
IoHandler.messageReceived(IoSession,Object)
event.messageReceived
in interface IoFilter
messageReceived
in class IoFilterAdapter
public void messageSent(IoFilter.NextFilter nextFilter, IoSession session, java.lang.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, java.lang.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 java.lang.Exception
IoFilter
IoSession.close()
method invocation.filterClose
in interface IoFilter
filterClose
in class IoFilterAdapter
java.lang.Exception
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.