org.apache.qpid.framing.amqp_0_9

Class MethodRegistry_0_9

java.lang.Object

org.apache.qpid.framing.MethodRegistry

org.apache.qpid.framing.amqp_0_9.MethodRegistry_0_9

public class MethodRegistry_0_9
extends MethodRegistry

Field Summary

Fields inherited from class org.apache.qpid.framing.MethodRegistry

registry_0_9, registry_0_91, registry_8_0

Constructor Summary

Constructors

Constructor and Description
MethodRegistry_0_9()
MethodRegistry_0_9(ProtocolVersion pv)

Method Summary

Methods

Modifier and Type	Method and Description
AMQMethodBody	convertToBody(MarkableDataInput in, long size)
AccessRequestBody	createAccessRequestBody(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
AccessRequestOkBody	createAccessRequestOkBody(int ticket)
BasicAckBody	createBasicAckBody(long deliveryTag, boolean multiple)
BasicCancelBody	createBasicCancelBody(AMQShortString consumerTag, boolean nowait)
BasicCancelOkBody	createBasicCancelOkBody(AMQShortString consumerTag)
BasicConsumeBody	createBasicConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable arguments)
BasicConsumeOkBody	createBasicConsumeOkBody(AMQShortString consumerTag)
BasicDeliverBody	createBasicDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey)
BasicGetBody	createBasicGetBody(int ticket, AMQShortString queue, boolean noAck)
BasicGetEmptyBody	createBasicGetEmptyBody(AMQShortString clusterId)
BasicGetOkBody	createBasicGetOkBody(long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, long messageCount)
BasicPublishBody	createBasicPublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
BasicQosBody	createBasicQosBody(long prefetchSize, int prefetchCount, boolean global)
BasicQosOkBody	createBasicQosOkBody()
BasicRecoverBody	createBasicRecoverBody(boolean requeue)
BasicRecoverSyncBody	createBasicRecoverSyncBody(boolean requeue)
BasicRecoverSyncOkBody	createBasicRecoverSyncOkBody()
BasicRejectBody	createBasicRejectBody(long deliveryTag, boolean requeue)
BasicReturnBody	createBasicReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
ChannelCloseBody	createChannelCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
ChannelCloseOkBody	createChannelCloseOkBody()
ChannelFlowBody	createChannelFlowBody(boolean active)
ChannelFlowOkBody	createChannelFlowOkBody(boolean active)
ChannelOkBody	createChannelOkBody()
ChannelOpenBody	createChannelOpenBody(AMQShortString outOfBand)
ChannelOpenOkBody	createChannelOpenOkBody(byte[] channelId)
ChannelPingBody	createChannelPingBody()
ChannelPongBody	createChannelPongBody()
ChannelResumeBody	createChannelResumeBody(byte[] channelId)
ConnectionCloseBody	createConnectionCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
ConnectionCloseOkBody	createConnectionCloseOkBody()
ConnectionOpenBody	createConnectionOpenBody(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
ConnectionOpenOkBody	createConnectionOpenOkBody(AMQShortString knownHosts)
ConnectionRedirectBody	createConnectionRedirectBody(AMQShortString host, AMQShortString knownHosts)
ConnectionSecureBody	createConnectionSecureBody(byte[] challenge)
ConnectionSecureOkBody	createConnectionSecureOkBody(byte[] response)
ConnectionStartBody	createConnectionStartBody(short versionMajor, short versionMinor, FieldTable serverProperties, byte[] mechanisms, byte[] locales)
ConnectionStartOkBody	createConnectionStartOkBody(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
ConnectionTuneBody	createConnectionTuneBody(int channelMax, long frameMax, int heartbeat)
ConnectionTuneOkBody	createConnectionTuneOkBody(int channelMax, long frameMax, int heartbeat)
DtxSelectBody	createDtxSelectBody()
DtxSelectOkBody	createDtxSelectOkBody()
DtxStartBody	createDtxStartBody(AMQShortString dtxIdentifier)
DtxStartOkBody	createDtxStartOkBody()
ExchangeBoundBody	createExchangeBoundBody(AMQShortString exchange, AMQShortString routingKey, AMQShortString queue)
ExchangeBoundOkBody	createExchangeBoundOkBody(int replyCode, AMQShortString replyText)
ExchangeDeclareBody	createExchangeDeclareBody(int ticket, AMQShortString exchange, AMQShortString type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, FieldTable arguments)
ExchangeDeclareOkBody	createExchangeDeclareOkBody()
ExchangeDeleteBody	createExchangeDeleteBody(int ticket, AMQShortString exchange, boolean ifUnused, boolean nowait)
ExchangeDeleteOkBody	createExchangeDeleteOkBody()
FileAckBody	createFileAckBody(long deliveryTag, boolean multiple)
FileCancelBody	createFileCancelBody(AMQShortString consumerTag, boolean nowait)
FileCancelOkBody	createFileCancelOkBody(AMQShortString consumerTag)
FileConsumeBody	createFileConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, FieldTable filter)
FileConsumeOkBody	createFileConsumeOkBody(AMQShortString consumerTag)
FileDeliverBody	createFileDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, AMQShortString identifier)
FileOpenBody	createFileOpenBody(AMQShortString identifier, long contentSize)
FileOpenOkBody	createFileOpenOkBody(long stagedSize)
FilePublishBody	createFilePublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate, AMQShortString identifier)
FileQosBody	createFileQosBody(long prefetchSize, int prefetchCount, boolean global)
FileQosOkBody	createFileQosOkBody()
FileRejectBody	createFileRejectBody(long deliveryTag, boolean requeue)
FileReturnBody	createFileReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
FileStageBody	createFileStageBody()
MessageAppendBody	createMessageAppendBody(byte[] reference, byte[] bytes)
MessageCancelBody	createMessageCancelBody(AMQShortString destination)
MessageCheckpointBody	createMessageCheckpointBody(byte[] reference, AMQShortString identifier)
MessageCloseBody	createMessageCloseBody(byte[] reference)
MessageConsumeBody	createMessageConsumeBody(int ticket, AMQShortString queue, AMQShortString destination, boolean noLocal, boolean noAck, boolean exclusive, FieldTable filter)
MessageEmptyBody	createMessageEmptyBody()
MessageGetBody	createMessageGetBody(int ticket, AMQShortString queue, AMQShortString destination, boolean noAck)
MessageOffsetBody	createMessageOffsetBody(long value)
MessageOkBody	createMessageOkBody()
MessageOpenBody	createMessageOpenBody(byte[] reference)
MessageQosBody	createMessageQosBody(long prefetchSize, int prefetchCount, boolean global)
MessageRecoverBody	createMessageRecoverBody(boolean requeue)
MessageRejectBody	createMessageRejectBody(int code, AMQShortString text)
MessageResumeBody	createMessageResumeBody(byte[] reference, AMQShortString identifier)
MessageTransferBody	createMessageTransferBody(int ticket, AMQShortString destination, boolean redelivered, boolean immediate, long ttl, short priority, long timestamp, short deliveryMode, long expiration, AMQShortString exchange, AMQShortString routingKey, AMQShortString messageId, AMQShortString correlationId, AMQShortString replyTo, AMQShortString contentType, AMQShortString contentEncoding, AMQShortString userId, AMQShortString appId, AMQShortString transactionId, byte[] securityToken, FieldTable applicationHeaders, Content body)
QueueBindBody	createQueueBindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, boolean nowait, FieldTable arguments)
QueueBindOkBody	createQueueBindOkBody()
QueueDeclareBody	createQueueDeclareBody(int ticket, AMQShortString queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, FieldTable arguments)
QueueDeclareOkBody	createQueueDeclareOkBody(AMQShortString queue, long messageCount, long consumerCount)
QueueDeleteBody	createQueueDeleteBody(int ticket, AMQShortString queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
QueueDeleteOkBody	createQueueDeleteOkBody(long messageCount)
QueuePurgeBody	createQueuePurgeBody(int ticket, AMQShortString queue, boolean nowait)
QueuePurgeOkBody	createQueuePurgeOkBody(long messageCount)
QueueUnbindBody	createQueueUnbindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, FieldTable arguments)
QueueUnbindOkBody	createQueueUnbindOkBody()
StreamCancelBody	createStreamCancelBody(AMQShortString consumerTag, boolean nowait)
StreamCancelOkBody	createStreamCancelOkBody(AMQShortString consumerTag)
StreamConsumeBody	createStreamConsumeBody(int ticket, AMQShortString queue, AMQShortString consumerTag, boolean noLocal, boolean exclusive, boolean nowait, FieldTable filter)
StreamConsumeOkBody	createStreamConsumeOkBody(AMQShortString consumerTag)
StreamDeliverBody	createStreamDeliverBody(AMQShortString consumerTag, long deliveryTag, AMQShortString exchange, AMQShortString queue)
StreamPublishBody	createStreamPublishBody(int ticket, AMQShortString exchange, AMQShortString routingKey, boolean mandatory, boolean immediate)
StreamQosBody	createStreamQosBody(long prefetchSize, int prefetchCount, long consumeRate, boolean global)
StreamQosOkBody	createStreamQosOkBody()
StreamReturnBody	createStreamReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
TunnelRequestBody	createTunnelRequestBody(FieldTable metaData)
TxCommitBody	createTxCommitBody()
TxCommitOkBody	createTxCommitOkBody()
TxRollbackBody	createTxRollbackBody()
TxRollbackOkBody	createTxRollbackOkBody()
TxSelectBody	createTxSelectBody()
TxSelectOkBody	createTxSelectOkBody()
int	getMaxClassId()
int	getMaxMethodId(int classId)
ProtocolVersionMethodConverter	getProtocolVersionMethodConverter()

Methods inherited from class org.apache.qpid.framing.MethodRegistry

getMethodRegistry

Methods inherited from class java.lang.Object

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

Constructor Detail

MethodRegistry_0_9

public MethodRegistry_0_9()

MethodRegistry_0_9

public MethodRegistry_0_9(ProtocolVersion pv)

Method Detail

convertToBody

public AMQMethodBody convertToBody(MarkableDataInput in,
                          long size)
                            throws AMQFrameDecodingException,
                                   IOException

Specified by:

convertToBody in class MethodRegistry

Throws:

AMQFrameDecodingException

IOException

getMaxClassId

public int getMaxClassId()

Specified by:

getMaxClassId in class MethodRegistry

getMaxMethodId

public int getMaxMethodId(int classId)

Specified by:

getMaxMethodId in class MethodRegistry

createConnectionStartBody

public ConnectionStartBody createConnectionStartBody(short versionMajor,
                                            short versionMinor,
                                            FieldTable serverProperties,
                                            byte[] mechanisms,
                                            byte[] locales)

Specified by:

createConnectionStartBody in class MethodRegistry

createConnectionStartOkBody

public ConnectionStartOkBody createConnectionStartOkBody(FieldTable clientProperties,
                                                AMQShortString mechanism,
                                                byte[] response,
                                                AMQShortString locale)

Specified by:

createConnectionStartOkBody in class MethodRegistry

createConnectionSecureBody

public ConnectionSecureBody createConnectionSecureBody(byte[] challenge)

Specified by:

createConnectionSecureBody in class MethodRegistry

createConnectionSecureOkBody

public ConnectionSecureOkBody createConnectionSecureOkBody(byte[] response)

Specified by:

createConnectionSecureOkBody in class MethodRegistry

createConnectionTuneBody

public ConnectionTuneBody createConnectionTuneBody(int channelMax,
                                          long frameMax,
                                          int heartbeat)

Specified by:

createConnectionTuneBody in class MethodRegistry

createConnectionTuneOkBody

public ConnectionTuneOkBody createConnectionTuneOkBody(int channelMax,
                                              long frameMax,
                                              int heartbeat)

Specified by:

createConnectionTuneOkBody in class MethodRegistry

createConnectionOpenBody

public ConnectionOpenBody createConnectionOpenBody(AMQShortString virtualHost,
                                          AMQShortString capabilities,
                                          boolean insist)

Specified by:

createConnectionOpenBody in class MethodRegistry

createConnectionOpenOkBody

public ConnectionOpenOkBody createConnectionOpenOkBody(AMQShortString knownHosts)

Specified by:

createConnectionOpenOkBody in class MethodRegistry

createConnectionRedirectBody

public ConnectionRedirectBody createConnectionRedirectBody(AMQShortString host,
                                                  AMQShortString knownHosts)

createConnectionCloseBody

public ConnectionCloseBody createConnectionCloseBody(int replyCode,
                                            AMQShortString replyText,
                                            int classId,
                                            int methodId)

Specified by:

createConnectionCloseBody in class MethodRegistry

createConnectionCloseOkBody

public ConnectionCloseOkBody createConnectionCloseOkBody()

Specified by:

createConnectionCloseOkBody in class MethodRegistry

createChannelOpenBody

public ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)

Specified by:

createChannelOpenBody in class MethodRegistry

createChannelOpenOkBody

public ChannelOpenOkBody createChannelOpenOkBody(byte[] channelId)

createChannelFlowBody

public ChannelFlowBody createChannelFlowBody(boolean active)

Specified by:

createChannelFlowBody in class MethodRegistry

createChannelFlowOkBody

public ChannelFlowOkBody createChannelFlowOkBody(boolean active)

Specified by:

createChannelFlowOkBody in class MethodRegistry

createChannelCloseBody

public ChannelCloseBody createChannelCloseBody(int replyCode,
                                      AMQShortString replyText,
                                      int classId,
                                      int methodId)

Specified by:

createChannelCloseBody in class MethodRegistry

createChannelCloseOkBody

public ChannelCloseOkBody createChannelCloseOkBody()

Specified by:

createChannelCloseOkBody in class MethodRegistry

createChannelResumeBody

public ChannelResumeBody createChannelResumeBody(byte[] channelId)

createChannelPingBody

public ChannelPingBody createChannelPingBody()

createChannelPongBody

public ChannelPongBody createChannelPongBody()

createChannelOkBody

public ChannelOkBody createChannelOkBody()

createAccessRequestBody

public AccessRequestBody createAccessRequestBody(AMQShortString realm,
                                        boolean exclusive,
                                        boolean passive,
                                        boolean active,
                                        boolean write,
                                        boolean read)

createAccessRequestOkBody

public AccessRequestOkBody createAccessRequestOkBody(int ticket)

createExchangeDeclareBody

public ExchangeDeclareBody createExchangeDeclareBody(int ticket,
                                            AMQShortString exchange,
                                            AMQShortString type,
                                            boolean passive,
                                            boolean durable,
                                            boolean autoDelete,
                                            boolean internal,
                                            boolean nowait,
                                            FieldTable arguments)

Specified by:

createExchangeDeclareBody in class MethodRegistry

createExchangeDeclareOkBody

public ExchangeDeclareOkBody createExchangeDeclareOkBody()

Specified by:

createExchangeDeclareOkBody in class MethodRegistry

createExchangeDeleteBody

public ExchangeDeleteBody createExchangeDeleteBody(int ticket,
                                          AMQShortString exchange,
                                          boolean ifUnused,
                                          boolean nowait)

Specified by:

createExchangeDeleteBody in class MethodRegistry

createExchangeDeleteOkBody

public ExchangeDeleteOkBody createExchangeDeleteOkBody()

Specified by:

createExchangeDeleteOkBody in class MethodRegistry

createExchangeBoundBody

public ExchangeBoundBody createExchangeBoundBody(AMQShortString exchange,
                                        AMQShortString routingKey,
                                        AMQShortString queue)

Specified by:

createExchangeBoundBody in class MethodRegistry

createExchangeBoundOkBody

public ExchangeBoundOkBody createExchangeBoundOkBody(int replyCode,
                                            AMQShortString replyText)

Specified by:

createExchangeBoundOkBody in class MethodRegistry

createQueueDeclareBody

public QueueDeclareBody createQueueDeclareBody(int ticket,
                                      AMQShortString queue,
                                      boolean passive,
                                      boolean durable,
                                      boolean exclusive,
                                      boolean autoDelete,
                                      boolean nowait,
                                      FieldTable arguments)

Specified by:

createQueueDeclareBody in class MethodRegistry

createQueueDeclareOkBody

public QueueDeclareOkBody createQueueDeclareOkBody(AMQShortString queue,
                                          long messageCount,
                                          long consumerCount)

Specified by:

createQueueDeclareOkBody in class MethodRegistry

createQueueBindBody

public QueueBindBody createQueueBindBody(int ticket,
                                AMQShortString queue,
                                AMQShortString exchange,
                                AMQShortString routingKey,
                                boolean nowait,
                                FieldTable arguments)

Specified by:

createQueueBindBody in class MethodRegistry

createQueueBindOkBody

public QueueBindOkBody createQueueBindOkBody()

Specified by:

createQueueBindOkBody in class MethodRegistry

createQueuePurgeBody

public QueuePurgeBody createQueuePurgeBody(int ticket,
                                  AMQShortString queue,
                                  boolean nowait)

Specified by:

createQueuePurgeBody in class MethodRegistry

createQueuePurgeOkBody

public QueuePurgeOkBody createQueuePurgeOkBody(long messageCount)

Specified by:

createQueuePurgeOkBody in class MethodRegistry

createQueueDeleteBody

public QueueDeleteBody createQueueDeleteBody(int ticket,
                                    AMQShortString queue,
                                    boolean ifUnused,
                                    boolean ifEmpty,
                                    boolean nowait)

Specified by:

createQueueDeleteBody in class MethodRegistry

createQueueDeleteOkBody

public QueueDeleteOkBody createQueueDeleteOkBody(long messageCount)

Specified by:

createQueueDeleteOkBody in class MethodRegistry

createQueueUnbindBody

public QueueUnbindBody createQueueUnbindBody(int ticket,
                                    AMQShortString queue,
                                    AMQShortString exchange,
                                    AMQShortString routingKey,
                                    FieldTable arguments)

createQueueUnbindOkBody

public QueueUnbindOkBody createQueueUnbindOkBody()

createBasicQosBody

public BasicQosBody createBasicQosBody(long prefetchSize,
                              int prefetchCount,
                              boolean global)

Specified by:

createBasicQosBody in class MethodRegistry

createBasicQosOkBody

public BasicQosOkBody createBasicQosOkBody()

Specified by:

createBasicQosOkBody in class MethodRegistry

createBasicConsumeBody

public BasicConsumeBody createBasicConsumeBody(int ticket,
                                      AMQShortString queue,
                                      AMQShortString consumerTag,
                                      boolean noLocal,
                                      boolean noAck,
                                      boolean exclusive,
                                      boolean nowait,
                                      FieldTable arguments)

Specified by:

createBasicConsumeBody in class MethodRegistry

createBasicConsumeOkBody

public BasicConsumeOkBody createBasicConsumeOkBody(AMQShortString consumerTag)

Specified by:

createBasicConsumeOkBody in class MethodRegistry

createBasicCancelBody

public BasicCancelBody createBasicCancelBody(AMQShortString consumerTag,
                                    boolean nowait)

Specified by:

createBasicCancelBody in class MethodRegistry

createBasicCancelOkBody

public BasicCancelOkBody createBasicCancelOkBody(AMQShortString consumerTag)

Specified by:

createBasicCancelOkBody in class MethodRegistry

createBasicPublishBody

public BasicPublishBody createBasicPublishBody(int ticket,
                                      AMQShortString exchange,
                                      AMQShortString routingKey,
                                      boolean mandatory,
                                      boolean immediate)

Specified by:

createBasicPublishBody in class MethodRegistry

createBasicReturnBody

public BasicReturnBody createBasicReturnBody(int replyCode,
                                    AMQShortString replyText,
                                    AMQShortString exchange,
                                    AMQShortString routingKey)

Specified by:

createBasicReturnBody in class MethodRegistry

createBasicDeliverBody

public BasicDeliverBody createBasicDeliverBody(AMQShortString consumerTag,
                                      long deliveryTag,
                                      boolean redelivered,
                                      AMQShortString exchange,
                                      AMQShortString routingKey)

Specified by:

createBasicDeliverBody in class MethodRegistry

createBasicGetBody

public BasicGetBody createBasicGetBody(int ticket,
                              AMQShortString queue,
                              boolean noAck)

Specified by:

createBasicGetBody in class MethodRegistry

createBasicGetOkBody

public BasicGetOkBody createBasicGetOkBody(long deliveryTag,
                                  boolean redelivered,
                                  AMQShortString exchange,
                                  AMQShortString routingKey,
                                  long messageCount)

Specified by:

createBasicGetOkBody in class MethodRegistry

createBasicGetEmptyBody

public BasicGetEmptyBody createBasicGetEmptyBody(AMQShortString clusterId)

Specified by:

createBasicGetEmptyBody in class MethodRegistry

createBasicAckBody

public BasicAckBody createBasicAckBody(long deliveryTag,
                              boolean multiple)

Specified by:

createBasicAckBody in class MethodRegistry

createBasicRejectBody

public BasicRejectBody createBasicRejectBody(long deliveryTag,
                                    boolean requeue)

Specified by:

createBasicRejectBody in class MethodRegistry

createBasicRecoverBody

public BasicRecoverBody createBasicRecoverBody(boolean requeue)

Specified by:

createBasicRecoverBody in class MethodRegistry

createBasicRecoverSyncOkBody

public BasicRecoverSyncOkBody createBasicRecoverSyncOkBody()

createBasicRecoverSyncBody

public BasicRecoverSyncBody createBasicRecoverSyncBody(boolean requeue)

createFileQosBody

public FileQosBody createFileQosBody(long prefetchSize,
                            int prefetchCount,
                            boolean global)

createFileQosOkBody

public FileQosOkBody createFileQosOkBody()

createFileConsumeBody

public FileConsumeBody createFileConsumeBody(int ticket,
                                    AMQShortString queue,
                                    AMQShortString consumerTag,
                                    boolean noLocal,
                                    boolean noAck,
                                    boolean exclusive,
                                    boolean nowait,
                                    FieldTable filter)

createFileConsumeOkBody

public FileConsumeOkBody createFileConsumeOkBody(AMQShortString consumerTag)

createFileCancelBody

public FileCancelBody createFileCancelBody(AMQShortString consumerTag,
                                  boolean nowait)

createFileCancelOkBody

public FileCancelOkBody createFileCancelOkBody(AMQShortString consumerTag)

createFileOpenBody

public FileOpenBody createFileOpenBody(AMQShortString identifier,
                              long contentSize)

createFileOpenOkBody

public FileOpenOkBody createFileOpenOkBody(long stagedSize)

createFileStageBody

public FileStageBody createFileStageBody()

createFilePublishBody

public FilePublishBody createFilePublishBody(int ticket,
                                    AMQShortString exchange,
                                    AMQShortString routingKey,
                                    boolean mandatory,
                                    boolean immediate,
                                    AMQShortString identifier)

createFileReturnBody

public FileReturnBody createFileReturnBody(int replyCode,
                                  AMQShortString replyText,
                                  AMQShortString exchange,
                                  AMQShortString routingKey)

createFileDeliverBody

public FileDeliverBody createFileDeliverBody(AMQShortString consumerTag,
                                    long deliveryTag,
                                    boolean redelivered,
                                    AMQShortString exchange,
                                    AMQShortString routingKey,
                                    AMQShortString identifier)

createFileAckBody

public FileAckBody createFileAckBody(long deliveryTag,
                            boolean multiple)

createFileRejectBody

public FileRejectBody createFileRejectBody(long deliveryTag,
                                  boolean requeue)

createStreamQosBody

public StreamQosBody createStreamQosBody(long prefetchSize,
                                int prefetchCount,
                                long consumeRate,
                                boolean global)

createStreamQosOkBody

public StreamQosOkBody createStreamQosOkBody()

createStreamConsumeBody

public StreamConsumeBody createStreamConsumeBody(int ticket,
                                        AMQShortString queue,
                                        AMQShortString consumerTag,
                                        boolean noLocal,
                                        boolean exclusive,
                                        boolean nowait,
                                        FieldTable filter)

createStreamConsumeOkBody

public StreamConsumeOkBody createStreamConsumeOkBody(AMQShortString consumerTag)

createStreamCancelBody

public StreamCancelBody createStreamCancelBody(AMQShortString consumerTag,
                                      boolean nowait)

createStreamCancelOkBody

public StreamCancelOkBody createStreamCancelOkBody(AMQShortString consumerTag)

createStreamPublishBody

public StreamPublishBody createStreamPublishBody(int ticket,
                                        AMQShortString exchange,
                                        AMQShortString routingKey,
                                        boolean mandatory,
                                        boolean immediate)

createStreamReturnBody

public StreamReturnBody createStreamReturnBody(int replyCode,
                                      AMQShortString replyText,
                                      AMQShortString exchange,
                                      AMQShortString routingKey)

createStreamDeliverBody

public StreamDeliverBody createStreamDeliverBody(AMQShortString consumerTag,
                                        long deliveryTag,
                                        AMQShortString exchange,
                                        AMQShortString queue)

createTxSelectBody

public TxSelectBody createTxSelectBody()

Specified by:

createTxSelectBody in class MethodRegistry

createTxSelectOkBody

public TxSelectOkBody createTxSelectOkBody()

Specified by:

createTxSelectOkBody in class MethodRegistry

createTxCommitBody

public TxCommitBody createTxCommitBody()

Specified by:

createTxCommitBody in class MethodRegistry

createTxCommitOkBody

public TxCommitOkBody createTxCommitOkBody()

Specified by:

createTxCommitOkBody in class MethodRegistry

createTxRollbackBody

public TxRollbackBody createTxRollbackBody()

Specified by:

createTxRollbackBody in class MethodRegistry

createTxRollbackOkBody

public TxRollbackOkBody createTxRollbackOkBody()

Specified by:

createTxRollbackOkBody in class MethodRegistry

createDtxSelectBody

public DtxSelectBody createDtxSelectBody()

createDtxSelectOkBody

public DtxSelectOkBody createDtxSelectOkBody()

createDtxStartBody

public DtxStartBody createDtxStartBody(AMQShortString dtxIdentifier)

createDtxStartOkBody

public DtxStartOkBody createDtxStartOkBody()

createTunnelRequestBody

public TunnelRequestBody createTunnelRequestBody(FieldTable metaData)

createMessageTransferBody

public MessageTransferBody createMessageTransferBody(int ticket,
                                            AMQShortString destination,
                                            boolean redelivered,
                                            boolean immediate,
                                            long ttl,
                                            short priority,
                                            long timestamp,
                                            short deliveryMode,
                                            long expiration,
                                            AMQShortString exchange,
                                            AMQShortString routingKey,
                                            AMQShortString messageId,
                                            AMQShortString correlationId,
                                            AMQShortString replyTo,
                                            AMQShortString contentType,
                                            AMQShortString contentEncoding,
                                            AMQShortString userId,
                                            AMQShortString appId,
                                            AMQShortString transactionId,
                                            byte[] securityToken,
                                            FieldTable applicationHeaders,
                                            Content body)

createMessageConsumeBody

public MessageConsumeBody createMessageConsumeBody(int ticket,
                                          AMQShortString queue,
                                          AMQShortString destination,
                                          boolean noLocal,
                                          boolean noAck,
                                          boolean exclusive,
                                          FieldTable filter)

createMessageCancelBody

public MessageCancelBody createMessageCancelBody(AMQShortString destination)

createMessageGetBody

public MessageGetBody createMessageGetBody(int ticket,
                                  AMQShortString queue,
                                  AMQShortString destination,
                                  boolean noAck)

createMessageRecoverBody

public MessageRecoverBody createMessageRecoverBody(boolean requeue)

createMessageOpenBody

public MessageOpenBody createMessageOpenBody(byte[] reference)

createMessageCloseBody

public MessageCloseBody createMessageCloseBody(byte[] reference)

createMessageAppendBody

public MessageAppendBody createMessageAppendBody(byte[] reference,
                                        byte[] bytes)

createMessageCheckpointBody

public MessageCheckpointBody createMessageCheckpointBody(byte[] reference,
                                                AMQShortString identifier)

createMessageResumeBody

public MessageResumeBody createMessageResumeBody(byte[] reference,
                                        AMQShortString identifier)

createMessageQosBody

public MessageQosBody createMessageQosBody(long prefetchSize,
                                  int prefetchCount,
                                  boolean global)

createMessageOkBody

public MessageOkBody createMessageOkBody()

createMessageEmptyBody

public MessageEmptyBody createMessageEmptyBody()

createMessageRejectBody

public MessageRejectBody createMessageRejectBody(int code,
                                        AMQShortString text)

createMessageOffsetBody

public MessageOffsetBody createMessageOffsetBody(long value)

getProtocolVersionMethodConverter

public ProtocolVersionMethodConverter getProtocolVersionMethodConverter()

Specified by:

getProtocolVersionMethodConverter in class MethodRegistry