public class MessageChannelFilter extends IoFilterAdapter
IoFilter.NextFilter
Modifier and Type | Field and Description |
---|---|
static int |
MAX_TIMEOUT |
static int |
MIN_TIMEOUT |
Constructor and Description |
---|
MessageChannelFilter(boolean clientMode) |
Modifier and Type | Method and Description |
---|---|
void |
filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoSession.write(Object) method invocation. |
Map<String,String> |
getAcceptedProperties() |
static boolean |
isOpened(IoSession session) |
static void |
markOpened(IoSession session) |
void |
messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object)
event. |
void |
sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
destroy, exceptionCaught, filterClose, init, messageSent, onPostAdd, onPostRemove, onPreAdd, onPreRemove, sessionClosed, sessionCreated, sessionIdle, toString
public static final int MAX_TIMEOUT
public static final int MIN_TIMEOUT
public void sessionOpened(IoFilter.NextFilter nextFilter, IoSession session) throws Exception
IoFilterAdapter
IoHandler.sessionOpened(IoSession)
event.sessionOpened
in interface IoFilter
sessionOpened
in class IoFilterAdapter
Exception
public void filterWrite(IoFilter.NextFilter nextFilter, IoSession session, WriteRequest writeRequest) throws Exception
IoFilterAdapter
IoSession.write(Object)
method invocation.filterWrite
in interface IoFilter
filterWrite
in class IoFilterAdapter
Exception
public void messageReceived(IoFilter.NextFilter nextFilter, IoSession session, Object message) throws Exception
IoFilterAdapter
IoHandler.messageReceived(IoSession,Object)
event.messageReceived
in interface IoFilter
messageReceived
in class IoFilterAdapter
Exception
public static boolean isOpened(IoSession session)
public static void markOpened(IoSession session)