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.netty |
Protocol codec which provides the integration with Netty2 messages.
|
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.reqres | |
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.integration.jmx |
JMX (Java Management eXtension) integration.
|
org.apache.mina.integration.ognl | |
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 java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
IoSession... sessions)
Writes the specified
message to the specified sessions . |
Modifier and Type | Method and Description |
---|---|
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.util.Collection<IoSession> sessions)
Writes the specified
message to the specified sessions . |
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.lang.Iterable<IoSession> sessions)
Writes the specified
message to the specified sessions . |
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.util.Iterator<IoSession> sessions)
Writes the specified
message to the specified sessions . |
Modifier and Type | Method and Description |
---|---|
IoSession |
IoFilterChain.getSession()
Returns the parent
IoSession of this chain. |
IoSession |
DefaultIoFilterChain.getSession() |
Modifier and Type | Method and Description |
---|---|
void |
IoFilterAdapter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
IoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable)
event. |
void |
IoFilter.NextFilter.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards exceptionCaught event to next filter.
|
void |
IoFilterAdapter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
close() method invocation. |
void |
IoFilter.NextFilter.filterClose(IoSession session)
Forwards filterClose event to next filter.
|
void |
IoFilterAdapter.filterSetTrafficMask(IoFilter.NextFilter nextFilter,
IoSession session,
TrafficMask trafficMask) |
void |
IoFilter.filterSetTrafficMask(IoFilter.NextFilter nextFilter,
IoSession session,
TrafficMask trafficMask)
Filters
setTrafficMask(TrafficMask) method invocation. |
void |
IoFilter.NextFilter.filterSetTrafficMask(IoSession session,
TrafficMask trafficMask)
Forwards filterSetTrafficMask event to next filter.
|
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
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.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
IoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object)
event. |
void |
IoFilter.NextFilter.messageReceived(IoSession session,
java.lang.Object message)
Forwards messageReceived event to next filter.
|
void |
IoFilterAdapter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
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) |
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) |
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) |
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) |
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,
java.lang.Object parameter) |
Modifier and Type | Method and Description |
---|---|
IoSession |
IoFuture.getSession()
Returns the
IoSession which is associated with this future. |
IoSession |
DefaultIoFuture.getSession()
Returns the
IoSession which is associated with this future. |
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,
java.lang.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) |
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(java.net.SocketAddress remoteAddress,
java.net.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. |
IoSession |
AbstractPollingConnectionlessIoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.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<T 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(java.net.SocketAddress remoteAddress,
java.net.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 |
---|---|
java.util.Map<java.lang.Long,IoSession> |
IoServiceListenerSupport.getManagedSessions() |
java.util.Map<java.lang.Long,IoSession> |
IoService.getManagedSessions()
Returns the map of all sessions which are currently managed by this
service.
|
java.util.Map<java.lang.Long,IoSession> |
AbstractIoService.getManagedSessions()
Returns the map of all sessions which are currently managed by this
service.
|
Modifier and Type | Method and Description |
---|---|
void |
IoHandlerAdapter.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
IoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
protected void |
AbstractIoService.finishSessionInitialization(IoSession session,
IoFuture future,
IoSessionInitializer sessionInitializer) |
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. |
void |
IoHandlerAdapter.messageReceived(IoSession session,
java.lang.Object message) |
void |
IoHandler.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
IoHandlerAdapter.messageSent(IoSession session,
java.lang.Object message) |
void |
IoHandler.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
IoHandlerAdapter.sessionClosed(IoSession session) |
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) |
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) |
void |
IoHandler.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
IoHandlerAdapter.sessionOpened(IoSession session) |
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(java.net.SocketAddress localAddress,
java.net.SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession . |
IoSession |
ExpiringSessionRecycler.recycle(java.net.SocketAddress localAddress,
java.net.SocketAddress remoteAddress) |
Modifier and Type | Method and Description |
---|---|
IoProcessor<IoSession> |
DummySession.getProcessor() |
Modifier and Type | Method and Description |
---|---|
boolean |
IoSessionAttributeMap.containsAttribute(IoSession session,
java.lang.Object key)
Returns true if this session contains the attribute with
the specified key.
|
void |
IoSessionAttributeMap.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
java.lang.Object |
IoSessionAttributeMap.getAttribute(IoSession session,
java.lang.Object key,
java.lang.Object defaultValue)
Returns the value of user defined attribute associated with the
specified key.
|
java.util.Set<java.lang.Object> |
IoSessionAttributeMap.getAttributeKeys(IoSession session)
Returns the set of keys of all user-defined attributes.
|
IoSessionAttributeMap |
IoSessionDataStructureFactory.getAttributeMap(IoSession session)
Returns an
IoSessionAttributeMap which is going to be associated
with the specified session. |
IoSessionAttributeMap |
DefaultIoSessionDataStructureFactory.getAttributeMap(IoSession session) |
WriteRequestQueue |
IoSessionDataStructureFactory.getWriteRequestQueue(IoSession session)
Returns an
WriteRequest which is going to be associated with
the specified session. |
WriteRequestQueue |
DefaultIoSessionDataStructureFactory.getWriteRequestQueue(IoSession session) |
void |
IoSessionInitializer.initializeSession(IoSession session,
T future) |
static void |
IdleStatusChecker.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) |
void |
IoSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
void |
ExpiringSessionRecycler.remove(IoSession session) |
java.lang.Object |
IoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key)
Removes a user-defined attribute with the specified key.
|
boolean |
IoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key,
java.lang.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,
java.lang.Object key,
java.lang.Object oldValue,
java.lang.Object newValue)
Replaces a user defined attribute with the specified key if the
value of the attribute is equals to the specified old value.
|
java.lang.Object |
IoSessionAttributeMap.setAttribute(IoSession session,
java.lang.Object key,
java.lang.Object value)
Sets a user-defined attribute.
|
java.lang.Object |
IoSessionAttributeMap.setAttributeIfAbsent(IoSession session,
java.lang.Object key,
java.lang.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 |
IdleStatusChecker.notifyIdleness(java.util.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,
java.lang.Object parameter) |
Modifier and Type | Method and Description |
---|---|
void |
WriteRequestQueue.clear(IoSession session) |
void |
WriteRequestQueue.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
boolean |
WriteRequestQueue.isEmpty(IoSession session) |
void |
WriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest) |
WriteRequest |
WriteRequestQueue.poll(IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
BufferedWriteFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.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) |
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
CumulativeProtocolDecoder.doDecode(IoSession, IoBuffer, ProtocolDecoderOutput) . |
void |
SynchronizedProtocolEncoder.dispose(IoSession session) |
void |
SynchronizedProtocolDecoder.dispose(IoSession session) |
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,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
ProtocolEncoder.encode(IoSession session,
java.lang.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) |
void |
SynchronizedProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
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.
|
ProtocolDecoder |
ProtocolCodecFilter.getDecoder(IoSession session) |
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) |
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,
java.lang.Object message) |
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ProtocolCodecFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
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) |
void |
DemuxingProtocolDecoder.dispose(IoSession session) |
protected boolean |
DemuxingProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
DemuxingProtocolEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
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) |
ProtocolDecoder |
DemuxingProtocolCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
DemuxingProtocolCodecFactory.getEncoder(IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
NettyDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
NettyEncoder.dispose(IoSession session) |
void |
NettyEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
ProtocolDecoder |
NettyCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
NettyCodecFactory.getEncoder(IoSession session) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
PrefixedStringDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
PrefixedStringEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
ProtocolDecoder |
PrefixedStringCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
PrefixedStringCodecFactory.getEncoder(IoSession session) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ObjectSerializationDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
ObjectSerializationEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
ProtocolDecoder |
ObjectSerializationCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
ObjectSerializationCodecFactory.getEncoder(IoSession session) |
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) |
void |
TextLineDecoder.dispose(IoSession session) |
void |
TextLineEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
TextLineDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
ProtocolDecoder |
TextLineCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
TextLineCodecFactory.getEncoder(IoSession session) |
protected void |
TextLineDecoder.writeText(IoSession session,
java.lang.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 java.lang.Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CompressionFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.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,
java.lang.Object message) |
Modifier and Type | Method and Description |
---|---|
void |
ExecutorFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
ExecutorFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ExecutorFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ExecutorFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
ExecutorFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ExecutorFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ExecutorFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ExecutorFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ExecutorFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
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,
java.lang.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 |
---|---|
java.lang.Object |
KeepAliveMessageFactory.getRequest(IoSession session)
Returns a (new) keep-alive request message.
|
java.lang.Object |
KeepAliveMessageFactory.getResponse(IoSession session,
java.lang.Object request)
Returns a (new) response message for the specified keep-alive request.
|
boolean |
KeepAliveMessageFactory.isRequest(IoSession session,
java.lang.Object message)
Returns true if and only if the specified message is a
keep-alive request message.
|
boolean |
KeepAliveMessageFactory.isResponse(IoSession session,
java.lang.Object message)
Returns true if and only if the specified message is a
keep-alive response 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,
java.lang.Object message) |
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
KeepAliveFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
Modifier and Type | Method and Description |
---|---|
void |
LoggingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
protected void |
MdcInjectionFilter.fillContext(IoSession session,
java.util.Map<java.lang.String,java.lang.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 java.lang.String |
MdcInjectionFilter.getProperty(IoSession session,
java.lang.String key) |
void |
LoggingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
static void |
MdcInjectionFilter.removeProperty(IoSession session,
java.lang.String key) |
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,
java.lang.String key,
java.lang.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 |
---|---|
protected java.util.Map<java.lang.Object,Request> |
RequestResponseFilter.createRequestStore(IoSession session)
|
protected java.util.Set<Request> |
RequestResponseFilter.createUnrespondedRequestStore(IoSession session)
|
protected java.lang.Object |
RequestResponseFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
RequestResponseFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
RequestResponseFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
SslFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
SslFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SslFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
javax.net.ssl.SSLSession |
SslFilter.getSslSession(IoSession session)
Returns the underlying
SSLSession for the specified session. |
boolean |
SslFilter.isSslStarted(IoSession session)
Returns true if and only if the specified session is
encrypted/decrypted over SSL/TLS currently.
|
void |
SslFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.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,
java.lang.Object message) |
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ProfilerTimerFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ProfilerTimerFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ProfilerTimerFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ProfilerTimerFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractStreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
Modifier and Type | Method and Description |
---|---|
protected abstract java.lang.Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
WriteRequestFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
ReferenceCountingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
CommonEventFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
ReferenceCountingFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.filterSetTrafficMask(IoFilter.NextFilter nextFilter,
IoSession session,
TrafficMask trafficMask) |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
CommonEventFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
WriteRequestFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
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) |
void |
CommonEventFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
CommonEventFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ReferenceCountingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
Modifier and Type | Method and Description |
---|---|
void |
IoHandlerCommand.execute(IoHandlerCommand.NextCommand next,
IoSession session,
java.lang.Object message)
Execute a unit of processing work to be performed.
|
void |
IoHandlerChain.execute(IoHandlerCommand.NextCommand next,
IoSession session,
java.lang.Object message) |
void |
IoHandlerCommand.NextCommand.execute(IoSession session,
java.lang.Object message)
Forwards the request to the next
IoHandlerCommand in the
IoHandlerChain . |
void |
ChainedIoHandler.messageReceived(IoSession session,
java.lang.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,
java.lang.Throwable cause) |
void |
MessageHandler.handleMessage(IoSession session,
E message)
Invoked when the specific type of message is received from or sent to
the specified
session . |
void |
DemuxingIoHandler.messageReceived(IoSession session,
java.lang.Object message)
Forwards the received events into the appropriate
MessageHandler
which is registered by DemuxingIoHandler.addReceivedMessageHandler(Class, MessageHandler) . |
void |
DemuxingIoHandler.messageSent(IoSession session,
java.lang.Object message) |
Modifier and Type | Method and Description |
---|---|
protected IoSession |
SingleSessionIoHandlerAdapter.getSession()
Retrieves the session to which this handler is assigned.
|
Modifier and Type | Method and Description |
---|---|
void |
SingleSessionIoHandlerDelegate.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Delegates the method call to the
SingleSessionIoHandler.exceptionCaught(Throwable) method of the
handler assigned to this session. |
SingleSessionIoHandler |
SingleSessionIoHandlerFactory.getHandler(IoSession session)
Returns a
SingleSessionIoHandler for the given session. |
void |
SingleSessionIoHandlerDelegate.messageReceived(IoSession session,
java.lang.Object message)
Delegates the method call to the
SingleSessionIoHandler.messageReceived(Object) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.messageSent(IoSession session,
java.lang.Object message)
Delegates the method call to the
SingleSessionIoHandler.messageSent(Object) method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionClosed(IoSession session)
Delegates the method call to the
SingleSessionIoHandler.sessionClosed() method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionCreated(IoSession session)
Creates a new instance with the factory passed to the constructor of
this class.
|
void |
SingleSessionIoHandlerDelegate.sessionIdle(IoSession session,
IdleStatus status)
Delegates the method call to the
SingleSessionIoHandler.sessionIdle(IdleStatus) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionOpened(IoSession session)
Delegates the method call to the
SingleSessionIoHandler.sessionOpened() method of the handler
assigned to this session. |
Constructor and Description |
---|
SingleSessionIoHandlerAdapter(IoSession session)
Creates a new instance that is assigned to the passed in session.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamIoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards caught exceptions to input stream.
|
void |
StreamIoHandler.messageReceived(IoSession session,
java.lang.Object buf)
Forwards read data to input stream.
|
protected abstract void |
StreamIoHandler.processStreamIo(IoSession session,
java.io.InputStream in,
java.io.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.
|
Constructor and Description |
---|
IoSessionMBean(IoSession source) |
Modifier and Type | Method and Description |
---|---|
java.util.Set<IoSession> |
IoSessionFinder.find(java.lang.Iterable<IoSession> sessions)
Finds a
Set of IoSession s that matches the query
from the specified sessions and returns the matches. |
Modifier and Type | Method and Description |
---|---|
java.util.Set<IoSession> |
IoSessionFinder.find(java.lang.Iterable<IoSession> sessions)
Finds a
Set of IoSession s that matches the query
from the specified sessions and returns the matches. |
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 |
VmPipeAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.