org.apache.qpid.framing.amqp_0_91
Class MethodRegistry_0_91
java.lang.Object
org.apache.qpid.framing.MethodRegistry
org.apache.qpid.framing.amqp_0_91.MethodRegistry_0_91
public class MethodRegistry_0_91
- extends MethodRegistry
Method Summary |
AMQMethodBody |
convertToBody(org.apache.mina.common.ByteBuffer in,
long size)
|
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)
|
ChannelOpenBody |
createChannelOpenBody(AMQShortString outOfBand)
|
ChannelOpenOkBody |
createChannelOpenOkBody(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)
|
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)
|
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()
|
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()
|
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_91
public MethodRegistry_0_91()
MethodRegistry_0_91
public MethodRegistry_0_91(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
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
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
createBasicRecoverSyncBody
public BasicRecoverSyncBody createBasicRecoverSyncBody(boolean requeue)
createBasicRecoverSyncOkBody
public BasicRecoverSyncOkBody createBasicRecoverSyncOkBody()
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
getProtocolVersionMethodConverter
public ProtocolVersionMethodConverter getProtocolVersionMethodConverter()
- Specified by:
getProtocolVersionMethodConverter
in class MethodRegistry
Licensed to the Apache Software Foundation