Package | Description |
---|---|
org.apache.mina.examples.sumup.codec | |
org.apache.mina.protocol |
High-level protocol implementation layer (Protocol layer).
|
org.apache.mina.protocol.codec |
Useful
ProtocolEncoder and ProtocolDecoder implementations. |
org.apache.mina.protocol.filter |
Basic
ProtocolHandlerFilter implementations. |
org.apache.mina.protocol.handler |
Useful
ProtocolHandler implementations. |
org.apache.mina.protocol.io |
A wrapper for
org.apache.mina.io package to support low-level I/O. |
org.apache.mina.protocol.vmpipe |
In-VM pipe support which removes the overhead of local loopback communication.
|
Modifier and Type | Method and Description |
---|---|
MessageDecoderResult |
AbstractMessageDecoder.decodable(ProtocolSession session,
ByteBuffer in) |
MessageDecoderResult |
AbstractMessageDecoder.decode(ProtocolSession session,
ByteBuffer in,
ProtocolDecoderOutput out) |
protected AbstractMessage |
AddMessageDecoder.decodeBody(ProtocolSession session,
ByteBuffer in) |
protected abstract AbstractMessage |
AbstractMessageDecoder.decodeBody(ProtocolSession session,
ByteBuffer in) |
protected AbstractMessage |
ResultMessageDecoder.decodeBody(ProtocolSession session,
ByteBuffer in) |
void |
AbstractMessageEncoder.encode(ProtocolSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
protected void |
ResultMessageEncoder.encodeBody(ProtocolSession session,
AbstractMessage message,
ByteBuffer out) |
protected void |
AddMessageEncoder.encodeBody(ProtocolSession session,
AbstractMessage message,
ByteBuffer out) |
protected abstract void |
AbstractMessageEncoder.encodeBody(ProtocolSession session,
AbstractMessage message,
ByteBuffer out) |
Modifier and Type | Method and Description |
---|---|
ProtocolSession |
ProtocolConnector.connect(java.net.SocketAddress address,
int timeout,
ProtocolProvider protocolProvider)
Connects to the specified
address with timeout. |
ProtocolSession |
ProtocolConnector.connect(java.net.SocketAddress address,
ProtocolProvider protocolProvider)
Connects to the specified
address . |
ProtocolSession |
ProtocolConnector.connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
int timeout,
ProtocolProvider protocolProvider)
Connects to the specified
address with timeout. |
ProtocolSession |
ProtocolConnector.connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
ProtocolProvider protocolProvider)
Connects to the specified
address . |
ProtocolSession |
ProtocolAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns a
ProtocolSession that is bound to the specified
localAddress and remoteAddress which reuses
the localAddress that is already bound by ProtocolAcceptor
via ProtocolAcceptor.bind(SocketAddress, ProtocolProvider) . |
Modifier and Type | Method and Description |
---|---|
void |
ProtocolDecoder.decode(ProtocolSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
protected void |
ProtocolSessionFilterChain.doWrite(ProtocolSession session,
java.lang.Object message) |
protected abstract void |
AbstractProtocolFilterChain.doWrite(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolEncoder.encode(ProtocolSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
ProtocolFilter.exceptionCaught(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Throwable cause)
Filters
ProtocolHandler.exceptionCaught(ProtocolSession,Throwable)
event. |
void |
ProtocolFilterAdapter.exceptionCaught(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Throwable cause) |
void |
ProtocolFilter.NextFilter.exceptionCaught(ProtocolSession session,
java.lang.Throwable cause) |
void |
ProtocolHandler.exceptionCaught(ProtocolSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
ProtocolHandler
implementation or by MINA. |
void |
AbstractProtocolFilterChain.exceptionCaught(ProtocolSession session,
java.lang.Throwable cause) |
void |
ProtocolHandlerAdapter.exceptionCaught(ProtocolSession session,
java.lang.Throwable cause) |
void |
ProtocolFilter.filterWrite(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message)
Filters
write(Object) method invocation. |
void |
ProtocolFilterAdapter.filterWrite(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolFilter.NextFilter.filterWrite(ProtocolSession session,
java.lang.Object message) |
void |
AbstractProtocolFilterChain.filterWrite(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolFilter.messageReceived(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message)
Filters
ProtocolHandler.messageReceived(ProtocolSession,Object)
event. |
void |
ProtocolFilterAdapter.messageReceived(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolFilter.NextFilter.messageReceived(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolHandler.messageReceived(ProtocolSession session,
java.lang.Object message)
Invoked when protocol message is received.
|
void |
AbstractProtocolFilterChain.messageReceived(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolHandlerAdapter.messageReceived(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolFilter.messageSent(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message)
Filters
ProtocolHandler.messageSent(ProtocolSession,Object)
event. |
void |
ProtocolFilterAdapter.messageSent(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolFilter.NextFilter.messageSent(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolHandler.messageSent(ProtocolSession session,
java.lang.Object message)
Invoked when protocol message that user requested by
write(Object) is sent out actually. |
void |
AbstractProtocolFilterChain.messageSent(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolHandlerAdapter.messageSent(ProtocolSession session,
java.lang.Object message) |
void |
ProtocolFilter.sessionClosed(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session)
Filters
ProtocolHandler.sessionClosed(ProtocolSession) event. |
void |
ProtocolFilterAdapter.sessionClosed(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session) |
void |
ProtocolFilter.NextFilter.sessionClosed(ProtocolSession session) |
void |
ProtocolHandler.sessionClosed(ProtocolSession session)
Invoked when the connection is closed.
|
void |
AbstractProtocolFilterChain.sessionClosed(ProtocolSession session) |
void |
ProtocolHandlerAdapter.sessionClosed(ProtocolSession session) |
void |
ProtocolHandler.sessionCreated(ProtocolSession session)
Invoked when the session is created.
|
void |
ProtocolHandlerAdapter.sessionCreated(ProtocolSession session) |
void |
ProtocolFilter.sessionIdle(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
IdleStatus status)
Filters
ProtocolHandler.sessionIdle(ProtocolSession,IdleStatus)
event. |
void |
ProtocolFilterAdapter.sessionIdle(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
IdleStatus status) |
void |
ProtocolFilter.NextFilter.sessionIdle(ProtocolSession session,
IdleStatus status) |
void |
ProtocolHandler.sessionIdle(ProtocolSession session,
IdleStatus status)
Invoked when the connection is idle.
|
void |
AbstractProtocolFilterChain.sessionIdle(ProtocolSession session,
IdleStatus status) |
void |
ProtocolHandlerAdapter.sessionIdle(ProtocolSession session,
IdleStatus status) |
void |
ProtocolFilter.sessionOpened(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session)
Filters
ProtocolHandler.sessionOpened(ProtocolSession) event. |
void |
ProtocolFilterAdapter.sessionOpened(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session) |
void |
ProtocolFilter.NextFilter.sessionOpened(ProtocolSession session) |
void |
ProtocolHandler.sessionOpened(ProtocolSession session)
Invoked when the connection is opened.
|
void |
AbstractProtocolFilterChain.sessionOpened(ProtocolSession session) |
void |
ProtocolHandlerAdapter.sessionOpened(ProtocolSession session) |
Modifier and Type | Method and Description |
---|---|
MessageDecoderResult |
MessageDecoder.decodable(ProtocolSession session,
ByteBuffer in)
Checks the specified buffer is decodable by this decoder.
|
void |
CumulativeProtocolDecoder.decode(ProtocolSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Cumulates content of in into internal buffer and forwards
decoding request to
CumulativeProtocolDecoder.doDecode(ProtocolSession, ByteBuffer, ProtocolDecoderOutput) . |
MessageDecoderResult |
MessageDecoder.decode(ProtocolSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
protected abstract boolean |
CumulativeProtocolDecoder.doDecode(ProtocolSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
Modifier and Type | Method and Description |
---|---|
void |
ProtocolThreadPoolFilter.exceptionCaught(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Throwable cause) |
void |
ProtocolLoggingFilter.exceptionCaught(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Throwable cause) |
void |
ProtocolThreadPoolFilter.filterWrite(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolLoggingFilter.filterWrite(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolThreadPoolFilter.messageReceived(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolLoggingFilter.messageReceived(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolThreadPoolFilter.messageSent(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolLoggingFilter.messageSent(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
java.lang.Object message) |
void |
ProtocolThreadPoolFilter.sessionClosed(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session) |
void |
ProtocolLoggingFilter.sessionClosed(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session) |
void |
ProtocolThreadPoolFilter.sessionIdle(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
IdleStatus status) |
void |
ProtocolLoggingFilter.sessionIdle(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session,
IdleStatus status) |
void |
ProtocolThreadPoolFilter.sessionOpened(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session) |
void |
ProtocolLoggingFilter.sessionOpened(ProtocolFilter.NextFilter nextFilter,
ProtocolSession session) |
Modifier and Type | Method and Description |
---|---|
void |
DemuxingProtocolHandler.messageReceived(ProtocolSession session,
java.lang.Object message)
Forwards the received events into the appropriate
MessageHandler
which is registered by DemuxingProtocolHandler.addMessageHandler(Class, MessageHandler) . |
void |
MessageHandler.messageReceived(ProtocolSession session,
java.lang.Object message)
Invoked when the specific type of message is received from the
specified
session . |
Modifier and Type | Class and Description |
---|---|
class |
IoProtocolSession
A
ProtocolSession that is backed by IoSession . |
Modifier and Type | Method and Description |
---|---|
ProtocolSession |
IoProtocolConnector.connect(java.net.SocketAddress address,
int timeout,
ProtocolProvider provider) |
ProtocolSession |
IoProtocolConnector.connect(java.net.SocketAddress address,
ProtocolProvider provider) |
ProtocolSession |
IoProtocolConnector.connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
int timeout,
ProtocolProvider provider) |
ProtocolSession |
IoProtocolConnector.connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
ProtocolProvider provider) |
ProtocolSession |
IoProtocolAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
Modifier and Type | Method and Description |
---|---|
ProtocolSession |
VmPipeConnector.connect(java.net.SocketAddress address,
int timeout,
ProtocolProvider protocolProvider) |
ProtocolSession |
VmPipeConnector.connect(java.net.SocketAddress address,
ProtocolProvider protocolProvider) |
ProtocolSession |
VmPipeConnector.connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
int timeout,
ProtocolProvider protocolProvider) |
ProtocolSession |
VmPipeConnector.connect(java.net.SocketAddress address,
java.net.SocketAddress localAddress,
ProtocolProvider protocolProvider) |
ProtocolSession |
VmPipeAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |