Package | Description |
---|---|
org.apache.mina.common |
Common types required for users to use MINA.
|
org.apache.mina.examples.sumup.codec | |
org.apache.mina.io |
Low-level protocol implementation layer (I/O layer).
|
org.apache.mina.io.filter |
Basic
IoHandlerFilter implementations. |
org.apache.mina.io.handler |
Useful
IoHandler implementations. |
org.apache.mina.protocol |
High-level protocol implementation layer (Protocol layer).
|
org.apache.mina.protocol.codec |
Useful
ProtocolEncoder and ProtocolDecoder implementations. |
Modifier and Type | Class and Description |
---|---|
class |
ByteBufferProxy
A
ByteBuffer that wraps a buffer and proxies any operations to it. |
Modifier and Type | Field and Description |
---|---|
protected ByteBuffer |
ByteBufferProxy.buf
The buffer proxied by this proxy.
|
Modifier and Type | Method and Description |
---|---|
static ByteBuffer |
ByteBuffer.allocate(int capacity)
Returns the direct or heap buffer which is capable of the specified
size.
|
static ByteBuffer |
ByteBuffer.allocate(int capacity,
boolean direct)
Returns the buffer which is capable of the specified size.
|
ByteBuffer |
ByteBufferProxy.clear() |
abstract ByteBuffer |
ByteBuffer.clear() |
ByteBuffer |
ByteBufferProxy.compact() |
abstract ByteBuffer |
ByteBuffer.compact() |
ByteBuffer |
ByteBufferProxy.fill(byte value,
int size) |
abstract ByteBuffer |
ByteBuffer.fill(byte value,
int size)
Fills this buffer with the specified value.
|
ByteBuffer |
ByteBufferProxy.fill(int size) |
abstract ByteBuffer |
ByteBuffer.fill(int size)
Fills this buffer with
NUL (0x00) . |
ByteBuffer |
ByteBufferProxy.fillAndReset(byte value,
int size) |
abstract ByteBuffer |
ByteBuffer.fillAndReset(byte value,
int size)
Fills this buffer with the specified value.
|
ByteBuffer |
ByteBufferProxy.fillAndReset(int size) |
abstract ByteBuffer |
ByteBuffer.fillAndReset(int size)
Fills this buffer with
NUL (0x00) . |
ByteBuffer |
ByteBufferProxy.flip() |
abstract ByteBuffer |
ByteBuffer.flip() |
ByteBuffer |
ByteBufferProxy.get(byte[] dst) |
abstract ByteBuffer |
ByteBuffer.get(byte[] dst) |
ByteBuffer |
ByteBufferProxy.get(byte[] dst,
int offset,
int length) |
abstract ByteBuffer |
ByteBuffer.get(byte[] dst,
int offset,
int length) |
ByteBuffer |
ByteBufferProxy.limit(int newLimit) |
abstract ByteBuffer |
ByteBuffer.limit(int newLimit) |
ByteBuffer |
ByteBufferProxy.mark() |
abstract ByteBuffer |
ByteBuffer.mark() |
ByteBuffer |
ByteBufferProxy.order(java.nio.ByteOrder bo) |
abstract ByteBuffer |
ByteBuffer.order(java.nio.ByteOrder bo) |
ByteBuffer |
ByteBufferProxy.position(int newPosition) |
abstract ByteBuffer |
ByteBuffer.position(int newPosition) |
ByteBuffer |
ByteBufferProxy.put(byte b) |
abstract ByteBuffer |
ByteBuffer.put(byte b) |
ByteBuffer |
ByteBufferProxy.put(byte[] src) |
abstract ByteBuffer |
ByteBuffer.put(byte[] src) |
ByteBuffer |
ByteBufferProxy.put(byte[] src,
int offset,
int length) |
abstract ByteBuffer |
ByteBuffer.put(byte[] src,
int offset,
int length) |
ByteBuffer |
ByteBufferProxy.put(ByteBuffer src) |
ByteBuffer |
ByteBufferProxy.put(java.nio.ByteBuffer src) |
abstract ByteBuffer |
ByteBuffer.put(java.nio.ByteBuffer src) |
abstract ByteBuffer |
ByteBuffer.put(ByteBuffer src) |
ByteBuffer |
ByteBufferProxy.put(int index,
byte b) |
abstract ByteBuffer |
ByteBuffer.put(int index,
byte b) |
ByteBuffer |
ByteBufferProxy.putChar(char value) |
abstract ByteBuffer |
ByteBuffer.putChar(char value) |
ByteBuffer |
ByteBufferProxy.putChar(int index,
char value) |
abstract ByteBuffer |
ByteBuffer.putChar(int index,
char value) |
ByteBuffer |
ByteBufferProxy.putDouble(double value) |
abstract ByteBuffer |
ByteBuffer.putDouble(double value) |
ByteBuffer |
ByteBufferProxy.putDouble(int index,
double value) |
abstract ByteBuffer |
ByteBuffer.putDouble(int index,
double value) |
ByteBuffer |
ByteBufferProxy.putFloat(float value) |
abstract ByteBuffer |
ByteBuffer.putFloat(float value) |
ByteBuffer |
ByteBufferProxy.putFloat(int index,
float value) |
abstract ByteBuffer |
ByteBuffer.putFloat(int index,
float value) |
ByteBuffer |
ByteBufferProxy.putInt(int value) |
abstract ByteBuffer |
ByteBuffer.putInt(int value) |
ByteBuffer |
ByteBufferProxy.putInt(int index,
int value) |
abstract ByteBuffer |
ByteBuffer.putInt(int index,
int value) |
ByteBuffer |
ByteBufferProxy.putLong(int index,
long value) |
abstract ByteBuffer |
ByteBuffer.putLong(int index,
long value) |
ByteBuffer |
ByteBufferProxy.putLong(long value) |
abstract ByteBuffer |
ByteBuffer.putLong(long value) |
ByteBuffer |
ByteBufferProxy.putShort(int index,
short value) |
abstract ByteBuffer |
ByteBuffer.putShort(int index,
short value) |
ByteBuffer |
ByteBufferProxy.putShort(short value) |
abstract ByteBuffer |
ByteBuffer.putShort(short value) |
ByteBuffer |
ByteBufferProxy.putString(java.lang.CharSequence in,
java.nio.charset.CharsetEncoder encoder) |
abstract ByteBuffer |
ByteBuffer.putString(java.lang.CharSequence in,
java.nio.charset.CharsetEncoder encoder)
Writes the content of
in into this buffer using the
specified encoder . |
ByteBuffer |
ByteBufferProxy.putString(java.lang.CharSequence in,
int fieldSize,
java.nio.charset.CharsetEncoder encoder) |
abstract ByteBuffer |
ByteBuffer.putString(java.lang.CharSequence in,
int fieldSize,
java.nio.charset.CharsetEncoder encoder)
Writes the content of
in into this buffer as a
NUL -terminated string using the specified
encoder . |
ByteBuffer |
ByteBufferProxy.reset() |
abstract ByteBuffer |
ByteBuffer.reset() |
ByteBuffer |
ByteBufferProxy.rewind() |
abstract ByteBuffer |
ByteBuffer.rewind() |
ByteBuffer |
ByteBufferProxy.setAutoExpand(boolean autoExpand) |
abstract ByteBuffer |
ByteBuffer.setAutoExpand(boolean autoExpand)
Turns on or off autoExpand.
|
ByteBuffer |
ByteBufferProxy.skip(int size) |
abstract ByteBuffer |
ByteBuffer.skip(int size)
Forwards the position of this buffer as the specified
size
bytes. |
static ByteBuffer |
ByteBuffer.wrap(byte[] byteArray)
Wraps the specified byte array into MINA heap buffer.
|
static ByteBuffer |
ByteBuffer.wrap(byte[] byteArray,
int offset,
int length)
Wraps the specified byte array into MINA heap buffer.
|
static ByteBuffer |
ByteBuffer.wrap(java.nio.ByteBuffer nioBuffer)
Wraps the specified NIO
ByteBuffer into MINA buffer. |
Modifier and Type | Method and Description |
---|---|
int |
ByteBufferProxy.compareTo(ByteBuffer that) |
abstract int |
ByteBuffer.compareTo(ByteBuffer that) |
ByteBuffer |
ByteBufferProxy.put(ByteBuffer src) |
abstract ByteBuffer |
ByteBuffer.put(ByteBuffer src) |
Constructor and Description |
---|
ByteBufferProxy(ByteBuffer buf)
Create a new instance.
|
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) |
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 |
---|---|
void |
IoFilter.dataRead(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf)
Filters
IoHandler.dataRead(IoSession, ByteBuffer) event. |
void |
IoFilterAdapter.dataRead(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf) |
void |
IoHandler.dataRead(IoSession session,
ByteBuffer buf)
Invoked when data is read from the connection.
|
void |
AbstractIoFilterChain.dataRead(IoSession session,
ByteBuffer buf) |
void |
IoFilter.NextFilter.dataRead(IoSession session,
ByteBuffer buf) |
void |
IoHandlerAdapter.dataRead(IoSession session,
ByteBuffer buf) |
protected abstract void |
AbstractIoFilterChain.doWrite(IoSession session,
ByteBuffer buffer,
java.lang.Object marker) |
protected void |
IoSessionFilterChain.doWrite(IoSession session,
ByteBuffer buf,
java.lang.Object marker) |
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf,
java.lang.Object marker)
Filters
IoSession.write(ByteBuffer, Object) method invocation. |
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf,
java.lang.Object marker) |
void |
AbstractIoFilterChain.filterWrite(IoSession session,
ByteBuffer buf,
java.lang.Object marker) |
void |
IoFilter.NextFilter.filterWrite(IoSession session,
ByteBuffer buf,
java.lang.Object marker) |
void |
IoSession.write(ByteBuffer buf,
java.lang.Object marker)
Writes the content of the specified
buf . |
Modifier and Type | Method and Description |
---|---|
void |
SSLFilter.dataRead(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf) |
void |
BlacklistFilter.dataRead(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf)
Forwards event if and if only the remote address of session is not
blacklisted.
|
void |
IoLoggingFilter.dataRead(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf) |
void |
IoThreadPoolFilter.dataRead(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf) |
void |
SSLFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf,
java.lang.Object marker) |
void |
IoLoggingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf,
java.lang.Object marker) |
void |
IoThreadPoolFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
ByteBuffer buf,
java.lang.Object marker) |
Modifier and Type | Method and Description |
---|---|
void |
StreamIoHandler.dataRead(IoSession session,
ByteBuffer buf)
Forwards read data to input stream.
|
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.
|
void |
ProtocolEncoderOutput.write(ByteBuffer buf)
Callback for
ProtocolEncoder to generate encoded
ByteBuffer s. |
void |
SimpleProtocolEncoderOutput.write(ByteBuffer buf) |
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).
|