org.apache.qpid.codec
Class AMQDecoder
java.lang.Object
org.apache.mina.filter.codec.ProtocolDecoderAdapter
org.apache.mina.filter.codec.CumulativeProtocolDecoder
org.apache.qpid.codec.AMQDecoder
- All Implemented Interfaces:
- org.apache.mina.filter.codec.ProtocolDecoder
public class AMQDecoder
- extends org.apache.mina.filter.codec.CumulativeProtocolDecoder
There is one instance of this class per session. Any changes or configuration done
at run time to the encoders or decoders only affects decoding/encoding of the
protocol session data to which is it bound.
Constructor Summary |
AMQDecoder(boolean expectProtocolInitiation)
|
Method Summary |
protected boolean |
doDecode(org.apache.mina.common.IoSession session,
org.apache.mina.common.ByteBuffer in,
org.apache.mina.filter.codec.ProtocolDecoderOutput out)
|
protected boolean |
doDecodeDataBlock(org.apache.mina.common.IoSession session,
org.apache.mina.common.ByteBuffer in,
org.apache.mina.filter.codec.ProtocolDecoderOutput out)
|
void |
setExpectProtocolInitiation(boolean expectProtocolInitiation)
|
Methods inherited from class org.apache.mina.filter.codec.CumulativeProtocolDecoder |
decode, dispose |
Methods inherited from class org.apache.mina.filter.codec.ProtocolDecoderAdapter |
finishDecode |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AMQDecoder
public AMQDecoder(boolean expectProtocolInitiation)
doDecode
protected boolean doDecode(org.apache.mina.common.IoSession session,
org.apache.mina.common.ByteBuffer in,
org.apache.mina.filter.codec.ProtocolDecoderOutput out)
throws java.lang.Exception
- Specified by:
doDecode
in class org.apache.mina.filter.codec.CumulativeProtocolDecoder
- Throws:
java.lang.Exception
doDecodeDataBlock
protected boolean doDecodeDataBlock(org.apache.mina.common.IoSession session,
org.apache.mina.common.ByteBuffer in,
org.apache.mina.filter.codec.ProtocolDecoderOutput out)
throws java.lang.Exception
- Throws:
java.lang.Exception
setExpectProtocolInitiation
public void setExpectProtocolInitiation(boolean expectProtocolInitiation)