Package | Description |
---|---|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractProtocolDecoderOutput
A
ProtocolDecoderOutput based on queue. |
Modifier and Type | Method and Description |
---|---|
ProtocolDecoderOutput |
ProtocolCodecSession.getDecoderOutput()
Returns the
ProtocolEncoderOutput that buffers
messages generated by ProtocolDecoder . |
Modifier and Type | Method and Description |
---|---|
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 |
ProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
SynchronizedProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
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 |
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 |
SynchronizedProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
Modifier and Type | Method and Description |
---|---|
MessageDecoderResult |
MessageDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
protected boolean |
DemuxingProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
DemuxingProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
MessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed while this decoder was
parsing the data.
|
void |
MessageDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
PrefixedStringDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ObjectSerializationDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
Modifier and Type | Method and Description |
---|---|
DecodingState |
CrLfDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
ShortIntegerDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
SkippingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
DecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
ConsumeToCrLfDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out) |
DecodingState |
SingleByteDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out) |
DecodingState |
FixedLengthDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
ConsumeToEndOfSessionDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
IntegerDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
ConsumeToDynamicTerminatorDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
ConsumeToTerminatorDecodingState.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
DecodingState |
DecodingStateMachine.decode(IoBuffer in,
ProtocolDecoderOutput out)
Invoked when data is available for this state.
|
void |
DecodingStateProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
protected abstract DecodingState |
CrLfDecodingState.finishDecode(boolean foundCRLF,
ProtocolDecoderOutput out)
Invoked when this state has found a
CRLF . |
protected abstract DecodingState |
SingleByteDecodingState.finishDecode(byte b,
ProtocolDecoderOutput out)
Invoked when this state has consumed a complete
byte . |
protected abstract DecodingState |
IntegerDecodingState.finishDecode(int value,
ProtocolDecoderOutput out)
Invoked when this state has consumed a complete
int . |
protected abstract DecodingState |
ConsumeToCrLfDecodingState.finishDecode(IoBuffer product,
ProtocolDecoderOutput out)
Invoked when this state has reached a
CRLF . |
protected abstract DecodingState |
FixedLengthDecodingState.finishDecode(IoBuffer product,
ProtocolDecoderOutput out)
Invoked when this state has consumed the configured number of bytes.
|
protected abstract DecodingState |
ConsumeToEndOfSessionDecodingState.finishDecode(IoBuffer product,
ProtocolDecoderOutput out)
Invoked when this state has consumed all bytes until the session is
closed.
|
protected abstract DecodingState |
ConsumeToDynamicTerminatorDecodingState.finishDecode(IoBuffer product,
ProtocolDecoderOutput out)
Invoked when this state has reached the terminator byte.
|
protected abstract DecodingState |
ConsumeToTerminatorDecodingState.finishDecode(IoBuffer product,
ProtocolDecoderOutput out)
Invoked when this state has reached the terminator byte.
|
void |
DecodingStateProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
protected abstract DecodingState |
DecodingStateMachine.finishDecode(java.util.List<java.lang.Object> childProducts,
ProtocolDecoderOutput out)
Called once the state machine has reached its end.
|
DecodingState |
CrLfDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
ShortIntegerDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
SkippingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
DecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
ConsumeToCrLfDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
SingleByteDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
FixedLengthDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
ConsumeToEndOfSessionDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
IntegerDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
ConsumeToDynamicTerminatorDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
ConsumeToTerminatorDecodingState.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
DecodingState |
DecodingStateMachine.finishDecode(ProtocolDecoderOutput out)
Invoked when the associated
IoSession is closed. |
protected abstract DecodingState |
ShortIntegerDecodingState.finishDecode(short value,
ProtocolDecoderOutput out)
Invoked when this state has consumed a complete
short . |
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.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
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) . |
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.