Package | Description |
---|---|
org.apache.mina.core |
Common types required for users to use MINA.
|
org.apache.mina.core.filterchain | |
org.apache.mina.core.future | |
org.apache.mina.core.polling |
Base class for implementing transport based on active polling strategies like NIO select call,
or any API based on I/O polling system calls (epoll, poll, select, kqueue, etc).
|
org.apache.mina.core.service | |
org.apache.mina.core.session | |
org.apache.mina.core.write | |
org.apache.mina.filter.buffer | |
org.apache.mina.filter.codec |
Filter implementations that helps you to implement complex protocols via 'codec' concept.
|
org.apache.mina.filter.codec.demux |
Protocol codecs that helps you to implement even more complex protocols by splitting a codec into multiple sub-codecs.
|
org.apache.mina.filter.codec.prefixedstring | |
org.apache.mina.filter.codec.serialization |
Protocol codecs which uses Java object serilization and leads to rapid protocol implementation.
|
org.apache.mina.filter.codec.statemachine | |
org.apache.mina.filter.codec.textline |
A protocol codec for text-based protocols.
|
org.apache.mina.filter.compression | |
org.apache.mina.filter.errorgenerating |
An IoFilter that provides flexible error generation facilities.
|
org.apache.mina.filter.executor |
IoFilters that provide flexible thread model and event queue monitoring interface.
|
org.apache.mina.filter.firewall |
Classes that implement IoFilter and provide host blocking and throttling.
|
org.apache.mina.filter.keepalive |
IoFilter that provides the ability for connections to remain open when data is not being transferred.
|
org.apache.mina.filter.logging |
Classes that implement IoFilter and provide logging of the events and data that flows through a MINA-based system.
|
org.apache.mina.filter.ssl |
Classes that implement IoFilter and provide Secure Sockets Layer functionality.
|
org.apache.mina.filter.statistic |
Classes that implement IoFilter and provide the ability for filters to be timed on their performance.
|
org.apache.mina.filter.stream |
Stream based IoFilter implementation.
|
org.apache.mina.filter.util |
Utility classes for the MINA filtering portion of the library.
|
org.apache.mina.handler.chain |
A handler implementation that helps you implement sequentially layered protocols using Chains of Responsibility pattern.
|
org.apache.mina.handler.demux |
A handler implementation that helps you implement complex protocols by splitting
messageReceived handlers into multiple sub-handlers.
|
org.apache.mina.handler.multiton |
Enables creating a handler per session instead of having one handler for many sessions, using Multiton pattern.
|
org.apache.mina.handler.stream | |
org.apache.mina.http | |
org.apache.mina.proxy | |
org.apache.mina.proxy.event | |
org.apache.mina.proxy.filter | |
org.apache.mina.proxy.handlers.http.digest | |
org.apache.mina.proxy.session | |
org.apache.mina.transport.socket.nio |
Socket (TCP/IP) and Datagram (UDP/IP) support based on Java NIO (New I/O) API.
|
org.apache.mina.transport.vmpipe |
In-VM pipe support which removes the overhead of local loopback communication.
|
Modifier and Type | Method and Description |
---|---|
static List<WriteFuture> |
IoUtil.broadcast(Object message,
IoSession... sessions)
Writes the specified
message to the specified sessions . |
Modifier and Type | Method and Description |
---|---|
static List<WriteFuture> |
IoUtil.broadcast(Object message,
Collection<IoSession> sessions)
Writes the specified
message to the specified sessions . |
static List<WriteFuture> |
IoUtil.broadcast(Object message,
Iterable<IoSession> sessions)
Writes the specified
message to the specified sessions . |
static List<WriteFuture> |
IoUtil.broadcast(Object message,
Iterator<IoSession> sessions)
Writes the specified
message to the specified sessions . |
Modifier and Type | Method and Description |
---|---|
IoSession |
DefaultIoFilterChain.getSession() |
IoSession |
IoFilterChain.getSession() |
Modifier and Type | Method and Description |
---|---|
void |
IoFilterAdapter.event(IoFilter.NextFilter nextFilter,
IoSession session,
FilterEvent event)
Propagate an event up to the
IoHandler |
void |
IoFilter.event(IoFilter.NextFilter nextFilter,
IoSession session,
FilterEvent event)
Propagate an event up to the
IoHandler |
void |
IoFilter.NextFilter.event(IoSession session,
FilterEvent event)
Forwards an event to next filter.
|
void |
IoFilterAdapter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilter.NextFilter.exceptionCaught(IoSession session,
Throwable cause)
Forwards
exceptionCaught event to next filter. |
void |
IoFilterAdapter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
closeNow() or a closeOnFlush() method invocations. |
void |
IoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
closeNow() or a closeOnFlush() method invocations. |
void |
IoFilter.NextFilter.filterClose(IoSession session)
Forwards
filterClose event to next filter. |
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
IoFilter.NextFilter.filterWrite(IoSession session,
WriteRequest writeRequest)
Forwards
filterWrite event to next filter. |
void |
IoFilterAdapter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilter.NextFilter.inputClosed(IoSession session) |
void |
IoFilterAdapter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilter.NextFilter.messageReceived(IoSession session,
Object message)
Forwards
messageReceived event to next filter. |
void |
IoFilterAdapter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilter.NextFilter.messageSent(IoSession session,
WriteRequest writeRequest)
Forwards
messageSent event to next filter. |
void |
IoFilterAdapter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilter.NextFilter.sessionClosed(IoSession session)
Forwards
sessionClosed event to next filter. |
void |
IoFilterAdapter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilter.NextFilter.sessionCreated(IoSession session)
Forwards
sessionCreated event to next filter. |
void |
IoFilterAdapter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilter.NextFilter.sessionIdle(IoSession session,
IdleStatus status)
Forwards
sessionIdle event to next filter. |
void |
IoFilterAdapter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilter.NextFilter.sessionOpened(IoSession session)
Forwards
sessionOpened event to next filter. |
Constructor and Description |
---|
IoFilterEvent(IoFilter.NextFilter nextFilter,
IoEventType type,
IoSession session,
Object parameter)
Creates a new IoFilterEvent instance
|
Modifier and Type | Method and Description |
---|---|
IoSession |
ConnectFuture.getSession()
Returns
IoSession which is the result of connect operation. |
IoSession |
DefaultIoFuture.getSession() |
IoSession |
DefaultConnectFuture.getSession() |
IoSession |
IoFuture.getSession() |
Modifier and Type | Method and Description |
---|---|
static WriteFuture |
DefaultWriteFuture.newNotWrittenFuture(IoSession session,
Throwable cause)
Returns a new
DefaultWriteFuture which is already marked as 'not written'. |
static WriteFuture |
DefaultWriteFuture.newWrittenFuture(IoSession session)
Returns a new
DefaultWriteFuture which is already marked as 'written'. |
void |
ConnectFuture.setSession(IoSession session)
Sets the newly connected session and notifies all threads waiting for
this future.
|
void |
DefaultConnectFuture.setSession(IoSession session)
Sets the newly connected session and notifies all threads waiting for
this future.
|
Constructor and Description |
---|
DefaultCloseFuture(IoSession session)
Creates a new instance.
|
DefaultIoFuture(IoSession session)
Creates a new instance associated with an
IoSession . |
DefaultReadFuture(IoSession session)
Creates a new instance.
|
DefaultWriteFuture(IoSession session)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
IoSession |
AbstractPollingIoAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress</tt> and the specified <tt>remoteAddress which
reuses the local address that is already bound by this service. |
Modifier and Type | Interface and Description |
---|---|
interface |
IoProcessor<S extends IoSession>
An internal interface to represent an 'I/O processor' that performs
actual I/O operations for
IoSession s. |
Modifier and Type | Method and Description |
---|---|
IoSession |
IoAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress</tt> and the specified <tt>remoteAddress which
reuses the local address that is already bound by this service. |
Modifier and Type | Method and Description |
---|---|
Map<Long,IoSession> |
IoServiceListenerSupport.getManagedSessions() |
Map<Long,IoSession> |
AbstractIoService.getManagedSessions() |
Map<Long,IoSession> |
IoService.getManagedSessions() |
Modifier and Type | Method and Description |
---|---|
void |
IoHandlerAdapter.event(IoSession session,
FilterEvent event)
Invoked when a filter event is fired.
|
void |
IoHandler.event(IoSession session,
FilterEvent event)
Invoked when a filter event is fired.
|
void |
IoHandlerAdapter.exceptionCaught(IoSession session,
Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
IoHandler.exceptionCaught(IoSession session,
Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
protected void |
AbstractIoService.finishSessionInitialization0(IoSession session,
IoFuture future)
Implement this method to perform additional tasks required for session
initialization.
|
protected void |
AbstractIoConnector.finishSessionInitialization0(IoSession session,
IoFuture future)
Adds required internal attributes and
IoFutureListener s
related with event notifications to the specified session
and future . |
void |
IoServiceListenerSupport.fireSessionCreated(IoSession session)
Calls
IoServiceListener.sessionCreated(IoSession) for all registered listeners. |
void |
IoServiceListenerSupport.fireSessionDestroyed(IoSession session)
Calls
IoServiceListener.sessionDestroyed(IoSession) for all registered listeners. |
protected void |
AbstractIoService.initSession(IoSession session,
IoFuture future,
IoSessionInitializer sessionInitializer) |
void |
IoHandlerAdapter.inputClosed(IoSession session)
Handle the closure of an half-duplex TCP channel
|
void |
IoHandler.inputClosed(IoSession session)
Handle the closure of an half-duplex TCP channel
|
void |
IoHandlerAdapter.messageReceived(IoSession session,
Object message)
Invoked when a message is received.
|
void |
IoHandler.messageReceived(IoSession session,
Object message)
Invoked when a message is received.
|
void |
IoHandlerAdapter.messageSent(IoSession session,
Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
IoHandler.messageSent(IoSession session,
Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
IoHandlerAdapter.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoServiceListener.sessionClosed(IoSession session)
Invoked when a new session is closed by an
IoService . |
void |
IoHandler.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoHandlerAdapter.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
IoServiceListener.sessionCreated(IoSession session)
Invoked when a new session is created by an
IoService . |
void |
IoHandler.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
IoServiceListener.sessionDestroyed(IoSession session)
Invoked when a session is being destroyed by an
IoService . |
void |
IoHandlerAdapter.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
IoHandler.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
IoHandlerAdapter.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
void |
IoHandler.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractIoSession
Base implementation of
IoSession . |
class |
DummySession
|
Modifier and Type | Method and Description |
---|---|
IoSession |
IoEvent.getSession() |
IoSession |
ExpiringSessionRecycler.recycle(SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession . |
IoSession |
IoSessionRecycler.recycle(SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession . |
Modifier and Type | Method and Description |
---|---|
IoProcessor<IoSession> |
DummySession.getProcessor() |
Modifier and Type | Method and Description |
---|---|
boolean |
IoSessionAttributeMap.containsAttribute(IoSession session,
Object key) |
void |
IoSessionAttributeMap.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
Object |
IoSessionAttributeMap.getAttribute(IoSession session,
Object key,
Object defaultValue) |
Set<Object> |
IoSessionAttributeMap.getAttributeKeys(IoSession session) |
IoSessionAttributeMap |
DefaultIoSessionDataStructureFactory.getAttributeMap(IoSession session) |
IoSessionAttributeMap |
IoSessionDataStructureFactory.getAttributeMap(IoSession session) |
WriteRequestQueue |
DefaultIoSessionDataStructureFactory.getWriteRequestQueue(IoSession session) |
WriteRequestQueue |
IoSessionDataStructureFactory.getWriteRequestQueue(IoSession session) |
void |
IoSessionInitializer.initializeSession(IoSession session,
T future)
Initialize a session
|
static void |
AbstractIoSession.notifyIdleSession(IoSession session,
long currentTime)
Fires a
IoEventType.SESSION_IDLE event if applicable for the
specified session . |
void |
ExpiringSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession . |
void |
IoSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession . |
void |
ExpiringSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
void |
IoSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
Object |
IoSessionAttributeMap.removeAttribute(IoSession session,
Object key)
Removes a user-defined attribute with the specified key.
|
boolean |
IoSessionAttributeMap.removeAttribute(IoSession session,
Object key,
Object value)
Removes a user defined attribute with the specified key if the current
attribute value is equal to the specified value.
|
boolean |
IoSessionAttributeMap.replaceAttribute(IoSession session,
Object key,
Object oldValue,
Object newValue)
Replaces a user defined attribute with the specified key if the
value of the attribute is equals to the specified old value.
|
Object |
IoSessionAttributeMap.setAttribute(IoSession session,
Object key,
Object value)
Sets a user-defined attribute.
|
Object |
IoSessionAttributeMap.setAttributeIfAbsent(IoSession session,
Object key,
Object value)
Sets a user defined attribute if the attribute with the specified key
is not set yet.
|
Modifier and Type | Method and Description |
---|---|
static void |
AbstractIoSession.notifyIdleness(Iterator<? extends IoSession> sessions,
long currentTime)
Fires a
IoEventType.SESSION_IDLE event to any applicable sessions
in the specified collection. |
Constructor and Description |
---|
IoEvent(IoEventType type,
IoSession session,
Object parameter)
Creates a new IoEvent
|
Modifier and Type | Method and Description |
---|---|
void |
WriteRequestQueue.clear(IoSession session)
Removes all the requests from this session's queue.
|
void |
WriteRequestQueue.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
boolean |
WriteRequestQueue.isEmpty(IoSession session)
Tells if the WriteRequest queue is empty or not for a session
|
void |
WriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest)
Add a new WriteRequest to the session write's queue
|
WriteRequest |
WriteRequestQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
Modifier and Type | Method and Description |
---|---|
void |
BufferedWriteFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
BufferedWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
BufferedWriteFilter.flush(IoSession session)
Flushes the buffered data.
|
void |
BufferedWriteFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
Constructor and Description |
---|
BufferedWriteFilter(int bufferSize,
LazyInitializedCacheMap<IoSession,IoBuffer> buffersMap)
Constructor which sets buffer size to
bufferSize . |
Modifier and Type | Class and Description |
---|---|
class |
ProtocolCodecSession
|
Modifier and Type | Method and Description |
---|---|
void |
SynchronizedProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
ProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
CumulativeProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Cumulates content of
in into internal buffer and forwards
decoding request to
doDecode(IoSession, IoBuffer, ProtocolDecoderOutput). |
void |
SynchronizedProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
SynchronizedProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
ProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
ProtocolDecoderAdapter.dispose(IoSession session)
Override this method to dispose all resources related with this decoder.
|
void |
CumulativeProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified
session . |
void |
ProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
ProtocolEncoderAdapter.dispose(IoSession session)
Override this method dispose all resources related with this encoder.
|
protected abstract boolean |
CumulativeProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
SynchronizedProtocolEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
ProtocolEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
ProtocolCodecFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
SynchronizedProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified
session is closed. |
void |
ProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified
session is closed. |
void |
ProtocolDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
ProtocolDecoderOutput.flush(IoFilter.NextFilter nextFilter,
IoSession session)
Flushes all messages you wrote via
ProtocolDecoderOutput.write(Object) to
the next filter. |
ProtocolDecoder |
ProtocolCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
ProtocolCodecFilter.getEncoder(IoSession session)
Get the encoder instance from a given session.
|
ProtocolEncoder |
ProtocolCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
void |
ProtocolCodecFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Process the incoming message, calling the session decoder.
|
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
ProtocolCodecFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
Modifier and Type | Method and Description |
---|---|
MessageDecoderResult |
MessageDecoder.decodable(IoSession session,
IoBuffer in)
Checks the specified buffer is decodable by this decoder.
|
MessageDecoderResult |
MessageDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
DemuxingProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified
session . |
void |
DemuxingProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
protected boolean |
DemuxingProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
DemuxingProtocolEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
MessageEncoder.encode(IoSession session,
T message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
MessageDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
DemuxingProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
MessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified
session is closed while this decoder was
parsing the data. |
ProtocolDecoder |
DemuxingProtocolCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
DemuxingProtocolCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
Modifier and Type | Method and Description |
---|---|
protected boolean |
PrefixedStringDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
PrefixedStringEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
ProtocolDecoder |
PrefixedStringCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
PrefixedStringCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ObjectSerializationDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
ObjectSerializationEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
ProtocolDecoder |
ObjectSerializationCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
ObjectSerializationCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
Modifier and Type | Method and Description |
---|---|
void |
DecodingStateProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
DecodingStateProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
DecodingStateProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified
session is closed. |
Modifier and Type | Method and Description |
---|---|
void |
TextLineDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
TextLineDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
TextLineEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
TextLineDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified
session is closed. |
ProtocolDecoder |
TextLineCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
TextLineCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
protected void |
TextLineDecoder.writeText(IoSession session,
String text,
ProtocolDecoderOutput out)
By default, this method propagates the decoded line of text to
ProtocolDecoderOutput#write(Object) . |
Modifier and Type | Method and Description |
---|---|
protected Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CompressionFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
CompressionFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
Modifier and Type | Method and Description |
---|---|
void |
ErrorGeneratingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ErrorGeneratingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
Constructor and Description |
---|
PriorityThreadPoolExecutor(Comparator<IoSession> comparator)
Creates a default ThreadPool, with default values : - minimum pool size is 0
- maximum pool size is 16 - keepAlive set to 30 seconds - A default
ThreadFactory - All events are accepted
|
PriorityThreadPoolExecutor(int maximumPoolSize,
Comparator<IoSession> comparator)
Creates a default ThreadPool, with default values : - minimum pool size is 0
- keepAlive set to 30 seconds - A default ThreadFactory - All events are
accepted
|
PriorityThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
ThreadFactory threadFactory,
IoEventQueueHandler eventQueueHandler,
Comparator<IoSession> comparator)
Creates a new instance of a PrioritisedOrderedThreadPoolExecutor.
|
Modifier and Type | Method and Description |
---|---|
void |
BlacklistFilter.event(IoFilter.NextFilter nextFilter,
IoSession session,
FilterEvent event)
Propagate an event up to the
IoHandler |
protected boolean |
ConnectionThrottleFilter.isConnectionOk(IoSession session)
Method responsible for deciding if a connection is OK
to continue
|
void |
BlacklistFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
BlacklistFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
ConnectionThrottleFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
BlacklistFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
Modifier and Type | Method and Description |
---|---|
Object |
KeepAliveMessageFactory.getRequest(IoSession session) |
Object |
KeepAliveMessageFactory.getResponse(IoSession session,
Object request) |
boolean |
KeepAliveMessageFactory.isRequest(IoSession session,
Object message) |
boolean |
KeepAliveMessageFactory.isResponse(IoSession session,
Object message) |
void |
KeepAliveRequestTimeoutHandler.keepAliveRequestTimedOut(KeepAliveFilter filter,
IoSession session)
Invoked when
KeepAliveFilter couldn't receive the response for
the sent keep alive message. |
void |
KeepAliveFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
KeepAliveFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
Modifier and Type | Method and Description |
---|---|
void |
LoggingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
protected void |
MdcInjectionFilter.fillContext(IoSession session,
Map<String,String> context)
write key properties of the session to the Mapped Diagnostic Context
sub-classes could override this method to map more/other attributes
|
static String |
MdcInjectionFilter.getProperty(IoSession session,
String key)
Get the property associated with a given key
|
void |
LoggingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
static void |
MdcInjectionFilter.removeProperty(IoSession session,
String key)
Remove a property from the context for the given session
This property will be removed from the MDC for all subsequent events
|
void |
LoggingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
LoggingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
LoggingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
LoggingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
static void |
MdcInjectionFilter.setProperty(IoSession session,
String key,
String value)
Add a property to the context for the given session
This property will be added to the MDC for all subsequent events
|
Modifier and Type | Method and Description |
---|---|
void |
SslFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause) |
void |
SslFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SslFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
SSLSession |
SslFilter.getSslSession(IoSession session)
Returns the underlying
SSLSession for the specified session. |
void |
SslFilter.initiateHandshake(IoSession session)
Initiate the SSL handshake.
|
boolean |
SslFilter.isSecured(IoSession session) |
boolean |
SslFilter.isSslStarted(IoSession session) |
void |
SslFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message) |
void |
SslFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
SslFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
boolean |
SslFilter.startSsl(IoSession session)
(Re)starts SSL session for the specified
session if not started yet. |
WriteFuture |
SslFilter.stopSsl(IoSession session)
Stops the SSL session by sending TLS
close_notify message to
initiate TLS closure. |
Modifier and Type | Method and Description |
---|---|
void |
ProfilerTimerFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Profile a MessageReceived event.
|
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Profile a MessageSent event.
|
void |
ProfilerTimerFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionClosed event.
|
void |
ProfilerTimerFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionCreated event.
|
void |
ProfilerTimerFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Profile a SessionIdle event.
|
void |
ProfilerTimerFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionOpened event.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractStreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
Modifier and Type | Method and Description |
---|---|
void |
CommonEventFilter.event(IoFilter.NextFilter nextFilter,
IoSession session,
FilterEvent event)
Propagate an event up to the
IoHandler |
void |
ReferenceCountingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
CommonEventFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
ReferenceCountingFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
closeNow() or a closeOnFlush() method invocations. |
void |
CommonEventFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
closeNow() or a closeOnFlush() method invocations. |
void |
ReferenceCountingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
CommonEventFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
CommonEventFilter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
ReferenceCountingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
CommonEventFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
ReferenceCountingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
CommonEventFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
ReferenceCountingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
CommonEventFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
ReferenceCountingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
SessionAttributeInitializingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Puts all pre-configured attributes into the actual session attribute
map and forward the event to the next filter.
|
void |
CommonEventFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
ReferenceCountingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
CommonEventFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
ReferenceCountingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
CommonEventFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
Modifier and Type | Method and Description |
---|---|
void |
IoHandlerChain.execute(IoHandlerCommand.NextCommand next,
IoSession session,
Object message)
Execute a unit of processing work to be performed.
|
void |
IoHandlerCommand.execute(IoHandlerCommand.NextCommand next,
IoSession session,
Object message)
Execute a unit of processing work to be performed.
|
void |
IoHandlerCommand.NextCommand.execute(IoSession session,
Object message)
Forwards the request to the next
IoHandlerCommand in the
IoHandlerChain . |
void |
ChainedIoHandler.messageReceived(IoSession session,
Object message)
Handles the specified
messageReceived event with the
IoHandlerCommand or IoHandlerChain you specified
in the constructor. |
Modifier and Type | Method and Description |
---|---|
void |
ExceptionHandler.exceptionCaught(IoSession session,
E cause)
Invoked when the specific type of exception is caught from the
specified
session . |
void |
DemuxingIoHandler.exceptionCaught(IoSession session,
Throwable cause)
Invoked when any exception is thrown by user IoHandler implementation
or by MINA.
|
void |
MessageHandler.handleMessage(IoSession session,
M message)
Invoked when the specific type of message is received from or sent to
the specified
session . |
void |
DemuxingIoHandler.messageReceived(IoSession session,
Object message)
Forwards the received events into the appropriate
MessageHandler
which is registered by DemuxingIoHandler.addReceivedMessageHandler(Class, MessageHandler) . |
void |
DemuxingIoHandler.messageSent(IoSession session,
Object message)
Invoked when a message written by IoSession.write(Object) is sent out.
|
Modifier and Type | Method and Description |
---|---|
protected IoSession |
SingleSessionIoHandlerAdapter.getSession()
Deprecated.
Retrieves the session to which this handler is assigned.
|
Modifier and Type | Method and Description |
---|---|
void |
SingleSessionIoHandlerDelegate.event(IoSession session,
FilterEvent event)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.event(FilterEvent) method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.exceptionCaught(IoSession session,
Throwable cause)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.exceptionCaught(Throwable) method of the
handler assigned to this session. |
SingleSessionIoHandler |
SingleSessionIoHandlerFactory.getHandler(IoSession session)
Deprecated.
|
void |
SingleSessionIoHandlerAdapter.inputClosed(IoSession session)
Deprecated.
Invoked when a half-duplex connection is closed
|
void |
SingleSessionIoHandler.inputClosed(IoSession session)
Deprecated.
Invoked when a half-duplex connection is closed
|
void |
SingleSessionIoHandlerDelegate.inputClosed(IoSession session)
Deprecated.
Handle the closure of an half-duplex TCP channel
|
void |
SingleSessionIoHandlerDelegate.messageReceived(IoSession session,
Object message)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.messageReceived(Object) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.messageSent(IoSession session,
Object message)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.messageSent(Object) method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionClosed(IoSession session)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.sessionClosed() method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionCreated(IoSession session)
Deprecated.
Creates a new instance with the factory passed to the constructor of
this class.
|
void |
SingleSessionIoHandlerDelegate.sessionIdle(IoSession session,
IdleStatus status)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.sessionIdle(IdleStatus) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionOpened(IoSession session)
Deprecated.
Delegates the method call to the
SingleSessionIoHandler.sessionOpened() method of the handler
assigned to this session. |
Constructor and Description |
---|
SingleSessionIoHandlerAdapter(IoSession session)
Deprecated.
Creates a new instance that is assigned to the passed in session.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamIoHandler.exceptionCaught(IoSession session,
Throwable cause)
Forwards caught exceptions to input stream.
|
void |
StreamIoHandler.messageReceived(IoSession session,
Object buf)
Forwards read data to input stream.
|
protected abstract void |
StreamIoHandler.processStreamIo(IoSession session,
InputStream in,
OutputStream out)
Implement this method to execute your stream I/O logic;
please note that you must forward the process request to other
thread or thread pool.
|
void |
StreamIoHandler.sessionClosed(IoSession session)
Closes streams
|
void |
StreamIoHandler.sessionIdle(IoSession session,
IdleStatus status)
Handles read timeout.
|
void |
StreamIoHandler.sessionOpened(IoSession session)
Initializes streams and timeout settings.
|
Modifier and Type | Method and Description |
---|---|
void |
HttpClientDecoder.decode(IoSession session,
IoBuffer msg,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
HttpServerDecoder.decode(IoSession session,
IoBuffer msg,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
HttpServerEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
HttpClientEncoder.dispose(IoSession arg0)
Releases all resources related with this encoder.
|
void |
HttpClientDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
HttpServerDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
HttpServerEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
HttpClientEncoder.encode(IoSession session,
Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
HttpClientDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified
session is closed. |
void |
HttpServerDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified
session is closed. |
void |
HttpServerCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
HttpClientCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
Modifier and Type | Method and Description |
---|---|
protected IoSession |
AbstractProxyLogicHandler.getSession() |
Modifier and Type | Method and Description |
---|---|
protected ConnectFuture |
ProxyConnector.fireConnected(IoSession session)
Fires the connection event on the real future to notify the client.
|
abstract void |
AbstractProxyIoHandler.proxySessionOpened(IoSession session)
Method called only when handshake has completed.
|
void |
AbstractProxyIoHandler.sessionOpened(IoSession session)
Hooked session opened event.
|
Modifier and Type | Method and Description |
---|---|
IoSession |
IoSessionEvent.getSession() |
Constructor and Description |
---|
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Creates an instance of this class when event type is
IoSessionEventType.IDLE . |
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IoSessionEventType type)
Creates an instance of this class when event type differs from
IoSessionEventType.IDLE . |
Modifier and Type | Method and Description |
---|---|
void |
ProxyFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
Throwable cause)
Called when an exception occurs in the chain.
|
void |
ProxyFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters outgoing writes, queueing them up if necessary while a handshake
is ongoing.
|
void |
ProxyFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
Object message)
Receives data from the remote host, passes to the handler if a handshake is in progress,
otherwise passes on transparently.
|
void |
ProxyFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filter handshake related messages from reaching the messageSent callbacks of
downstream filters.
|
void |
ProxyFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Called when the session is created.
|
void |
ProxyFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.writeData(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest,
boolean isHandshakeData)
Actually write data.
|
Modifier and Type | Method and Description |
---|---|
static String |
DigestUtilities.computeResponseValue(IoSession session,
Map<String,String> map,
String method,
String pwd,
String charsetName,
String body)
Computes the response to the DIGEST challenge.
|
Modifier and Type | Method and Description |
---|---|
IoSession |
ProxyIoSession.getSession() |
Modifier and Type | Method and Description |
---|---|
void |
ProxyIoSessionInitializer.initializeSession(IoSession session,
T future)
Initialize a session
|
void |
ProxyIoSession.setSession(IoSession session)
Sets the
IoSession in use. |
Modifier and Type | Class and Description |
---|---|
class |
NioSession
An
IoSession which is managed by the NIO transport. |
Modifier and Type | Method and Description |
---|---|
IoSession |
NioDatagramAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress</tt> and the specified <tt>remoteAddress which
reuses the local address that is already bound by this service. |
Modifier and Type | Method and Description |
---|---|
IoSession |
VmPipeAcceptor.newSession(SocketAddress remoteAddress,
SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress</tt> and the specified <tt>remoteAddress which
reuses the local address that is already bound by this service. |
Copyright © 2004–2024 Apache MINA Project. All rights reserved.