org.apache.qpid.server.protocol.v0_8

Class BrokerDecoder

java.lang.Object

org.apache.qpid.codec.AMQDecoder<ServerMethodProcessor<? extends ServerChannelMethodProcessor>>

org.apache.qpid.codec.ServerDecoder

org.apache.qpid.server.protocol.v0_8.BrokerDecoder

public class BrokerDecoder
extends ServerDecoder

Constructor Summary

Constructors

Constructor and Description
BrokerDecoder(AMQPConnection_0_8 connection) Creates a new AMQP decoder.

Method Summary

Modifier and Type	Method and Description
protected void	processFrame(int channelId, byte type, long bodySize, MarkableDataInput in)

Methods inherited from class org.apache.qpid.codec.ServerDecoder

decodeBuffer

Methods inherited from class org.apache.qpid.codec.AMQDecoder

decode, getMethodProcessor, setExpectProtocolInitiation, setMaxFrameSize

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BrokerDecoder

public BrokerDecoder(AMQPConnection_0_8 connection)

Creates a new AMQP decoder.

Parameters:

connection -

Method Detail

processFrame

protected void processFrame(int channelId,
                            byte type,
                            long bodySize,
                            MarkableDataInput in)
                     throws AMQFrameDecodingException,
                            IOException

Overrides:

processFrame in class AMQDecoder<ServerMethodProcessor<? extends ServerChannelMethodProcessor>>

Throws:

AMQFrameDecodingException

IOException