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.integration.jmx |
JMX (Java Management eXtension) integration.
|
org.apache.mina.integration.ognl | |
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.serial | |
org.apache.mina.transport.socket.apr | |
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 |
IoFilterChain.getSession() |
IoSession |
DefaultIoFilterChain.getSession() |
Modifier and Type | Method and Description |
---|---|
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 |
IoFuture.getSession() |
IoSession |
DefaultIoFuture.getSession() |
IoSession |
DefaultConnectFuture.getSession() |
IoSession |
ConnectFuture.getSession()
Returns
IoSession which is the result of connect operation. |
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 |
DefaultConnectFuture.setSession(IoSession session)
Sets the newly connected session and notifies all threads waiting for
this future.
|
void |
ConnectFuture.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 and the specified 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 and the specified 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> |
IoService.getManagedSessions() |
Map<Long,IoSession> |
AbstractIoService.getManagedSessions() |
Modifier and Type | Method and Description |
---|---|
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 |
IoServiceListener.sessionClosed(IoSession session)
Invoked when a new session is closed by an
IoService . |
void |
IoHandlerAdapter.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoHandler.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoServiceListener.sessionCreated(IoSession session)
Invoked when a new session is created by an
IoService . |
void |
IoHandlerAdapter.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
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 |
IoSessionRecycler.recycle(SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession . |
IoSession |
ExpiringSessionRecycler.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 |
IoSessionDataStructureFactory.getAttributeMap(IoSession session) |
IoSessionAttributeMap |
DefaultIoSessionDataStructureFactory.getAttributeMap(IoSession session) |
WriteRequestQueue |
IoSessionDataStructureFactory.getWriteRequestQueue(IoSession session) |
WriteRequestQueue |
DefaultIoSessionDataStructureFactory.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 |
IoSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession . |
void |
ExpiringSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession . |
void |
IoSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
void |
ExpiringSessionRecycler.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 |
ProtocolEncoderAdapter.dispose(IoSession session)
Override this method dispose all resources related with this encoder.
|
void |
ProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
ProtocolDecoderAdapter.dispose(IoSession session)
Override this method to dispose all resources related with this decoder.
|
void |
ProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
CumulativeProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified session.
|
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 |
ProtocolDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
ProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
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 |
DemuxingProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
DemuxingProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified session.
|
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 |
MessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed while this decoder was
parsing the data.
|
void |
DemuxingProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
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.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) |
Modifier and Type | Method and Description |
---|---|
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) |
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
BlacklistFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ConnectionThrottleFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
BlacklistFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
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) |
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) |
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
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) |
void |
LoggingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
LoggingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
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 |
---|---|
protected abstract Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
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 |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
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 |
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 |
WriteRequestFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(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 |
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 |
ReferenceCountingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
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 |
IoHandlerCommand.execute(IoHandlerCommand.NextCommand next,
IoSession session,
Object message)
Execute a unit of processing work to be performed.
|
void |
IoHandlerChain.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.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 |
SingleSessionIoHandlerDelegate.inputClosed(IoSession session)
Deprecated.
Handle the closure of an half-duplex TCP channel
|
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.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 |
HttpServerDecoder.decode(IoSession session,
IoBuffer msg,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
HttpClientDecoder.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 |
HttpServerDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
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 |
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 |
HttpServerDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
void |
HttpClientDecoder.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. |
Constructor and Description |
---|
IoSessionMBean(IoSession source)
Creates a new IoSessionMBean instance
|
Modifier and Type | Method and Description |
---|---|
Set<IoSession> |
IoSessionFinder.find(Iterable<IoSession> sessions)
|
Modifier and Type | Method and Description |
---|---|
Set<IoSession> |
IoSessionFinder.find(Iterable<IoSession> sessions)
|
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 | Interface and Description |
---|---|
interface |
SerialSession
An
IoSession for serial communication transport. |
Modifier and Type | Class and Description |
---|---|
class |
AprSession
An abstract
IoSession serving of base for APR based sessions. |
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 and the specified 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 and the specified remoteAddress which
reuses the local address that is already bound by this service. |
Copyright © 2004–2018 Apache MINA Project. All rights reserved.