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
Method Summary |
AMQMethodBody |
convertToBody(org.apache.mina.common.ByteBuffer 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 java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MethodRegistry_0_9
public MethodRegistry_0_9()
MethodRegistry_0_9
public MethodRegistry_0_9(ProtocolVersion pv)
convertToBody
public AMQMethodBody convertToBody(org.apache.mina.common.ByteBuffer in,
long size)
throws AMQFrameDecodingException
- Specified by:
convertToBody
in class MethodRegistry
- Throws:
AMQFrameDecodingException
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
Licensed to the Apache Software Foundation