org.apache.qpid.framing
Class MethodRegistry
java.lang.Object
org.apache.qpid.framing.MethodRegistry
- Direct Known Subclasses:
- MethodRegistry_0_9, MethodRegistry_0_91, MethodRegistry_8_0
public abstract class MethodRegistry
- extends Object
Method Summary |
abstract AMQMethodBody |
convertToBody(org.apache.mina.common.ByteBuffer in,
long size)
|
abstract BasicAckBody |
createBasicAckBody(long deliveryTag,
boolean multiple)
|
abstract BasicCancelBody |
createBasicCancelBody(AMQShortString consumerTag,
boolean nowait)
|
abstract BasicCancelOkBody |
createBasicCancelOkBody(AMQShortString consumerTag)
|
abstract BasicConsumeBody |
createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
|
abstract BasicConsumeOkBody |
createBasicConsumeOkBody(AMQShortString consumerTag)
|
abstract BasicDeliverBody |
createBasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
|
abstract BasicGetBody |
createBasicGetBody(int ticket,
AMQShortString queue,
boolean noAck)
|
abstract BasicGetEmptyBody |
createBasicGetEmptyBody(AMQShortString clusterId)
|
abstract BasicGetOkBody |
createBasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
|
abstract BasicPublishBody |
createBasicPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
|
abstract BasicQosBody |
createBasicQosBody(long prefetchSize,
int prefetchCount,
boolean global)
|
abstract BasicQosOkBody |
createBasicQosOkBody()
|
abstract BasicRecoverBody |
createBasicRecoverBody(boolean requeue)
|
abstract BasicRejectBody |
createBasicRejectBody(long deliveryTag,
boolean requeue)
|
abstract BasicReturnBody |
createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
|
abstract ChannelCloseBody |
createChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
abstract ChannelCloseOkBody |
createChannelCloseOkBody()
|
abstract ChannelFlowBody |
createChannelFlowBody(boolean active)
|
abstract ChannelFlowOkBody |
createChannelFlowOkBody(boolean active)
|
abstract ChannelOpenBody |
createChannelOpenBody(AMQShortString outOfBand)
|
abstract ConnectionCloseBody |
createConnectionCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
|
abstract ConnectionCloseOkBody |
createConnectionCloseOkBody()
|
abstract ConnectionOpenBody |
createConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
|
abstract ConnectionOpenOkBody |
createConnectionOpenOkBody(AMQShortString knownHosts)
|
abstract ConnectionSecureBody |
createConnectionSecureBody(byte[] challenge)
|
abstract ConnectionSecureOkBody |
createConnectionSecureOkBody(byte[] response)
|
abstract ConnectionStartBody |
createConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales)
|
abstract ConnectionStartOkBody |
createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
|
abstract ConnectionTuneBody |
createConnectionTuneBody(int channelMax,
long frameMax,
int heartbeat)
|
abstract ConnectionTuneOkBody |
createConnectionTuneOkBody(int channelMax,
long frameMax,
int heartbeat)
|
abstract ExchangeBoundBody |
createExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
|
abstract ExchangeBoundOkBody |
createExchangeBoundOkBody(int replyCode,
AMQShortString replyText)
|
abstract ExchangeDeclareBody |
createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
|
abstract ExchangeDeclareOkBody |
createExchangeDeclareOkBody()
|
abstract ExchangeDeleteBody |
createExchangeDeleteBody(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
|
abstract ExchangeDeleteOkBody |
createExchangeDeleteOkBody()
|
abstract QueueBindBody |
createQueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments)
|
abstract QueueBindOkBody |
createQueueBindOkBody()
|
abstract QueueDeclareBody |
createQueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments)
|
abstract QueueDeclareOkBody |
createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount)
|
abstract QueueDeleteBody |
createQueueDeleteBody(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
|
abstract QueueDeleteOkBody |
createQueueDeleteOkBody(long messageCount)
|
abstract QueuePurgeBody |
createQueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait)
|
abstract QueuePurgeOkBody |
createQueuePurgeOkBody(long messageCount)
|
abstract TxCommitBody |
createTxCommitBody()
|
abstract TxCommitOkBody |
createTxCommitOkBody()
|
abstract TxRollbackBody |
createTxRollbackBody()
|
abstract TxRollbackOkBody |
createTxRollbackOkBody()
|
abstract TxSelectBody |
createTxSelectBody()
|
abstract TxSelectOkBody |
createTxSelectOkBody()
|
abstract int |
getMaxClassId()
|
abstract int |
getMaxMethodId(int classId)
|
static MethodRegistry |
getMethodRegistry(ProtocolVersion pv)
|
abstract ProtocolVersionMethodConverter |
getProtocolVersionMethodConverter()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
registry_0_9
public static final MethodRegistry registry_0_9
registry_0_91
public static final MethodRegistry registry_0_91
registry_8_0
public static final MethodRegistry registry_8_0
MethodRegistry
protected MethodRegistry(ProtocolVersion pv)
convertToBody
public abstract AMQMethodBody convertToBody(org.apache.mina.common.ByteBuffer in,
long size)
throws AMQFrameDecodingException
- Throws:
AMQFrameDecodingException
getMaxClassId
public abstract int getMaxClassId()
getMaxMethodId
public abstract int getMaxMethodId(int classId)
getMethodRegistry
public static MethodRegistry getMethodRegistry(ProtocolVersion pv)
createBasicAckBody
public abstract BasicAckBody createBasicAckBody(long deliveryTag,
boolean multiple)
createBasicCancelBody
public abstract BasicCancelBody createBasicCancelBody(AMQShortString consumerTag,
boolean nowait)
createBasicCancelOkBody
public abstract BasicCancelOkBody createBasicCancelOkBody(AMQShortString consumerTag)
createBasicConsumeBody
public abstract BasicConsumeBody createBasicConsumeBody(int ticket,
AMQShortString queue,
AMQShortString consumerTag,
boolean noLocal,
boolean noAck,
boolean exclusive,
boolean nowait,
FieldTable arguments)
createBasicConsumeOkBody
public abstract BasicConsumeOkBody createBasicConsumeOkBody(AMQShortString consumerTag)
createBasicDeliverBody
public abstract BasicDeliverBody createBasicDeliverBody(AMQShortString consumerTag,
long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey)
createBasicGetBody
public abstract BasicGetBody createBasicGetBody(int ticket,
AMQShortString queue,
boolean noAck)
createBasicGetEmptyBody
public abstract BasicGetEmptyBody createBasicGetEmptyBody(AMQShortString clusterId)
createBasicGetOkBody
public abstract BasicGetOkBody createBasicGetOkBody(long deliveryTag,
boolean redelivered,
AMQShortString exchange,
AMQShortString routingKey,
long messageCount)
createBasicPublishBody
public abstract BasicPublishBody createBasicPublishBody(int ticket,
AMQShortString exchange,
AMQShortString routingKey,
boolean mandatory,
boolean immediate)
createBasicQosBody
public abstract BasicQosBody createBasicQosBody(long prefetchSize,
int prefetchCount,
boolean global)
createBasicQosOkBody
public abstract BasicQosOkBody createBasicQosOkBody()
createBasicRecoverBody
public abstract BasicRecoverBody createBasicRecoverBody(boolean requeue)
createBasicRejectBody
public abstract BasicRejectBody createBasicRejectBody(long deliveryTag,
boolean requeue)
createBasicReturnBody
public abstract BasicReturnBody createBasicReturnBody(int replyCode,
AMQShortString replyText,
AMQShortString exchange,
AMQShortString routingKey)
createChannelCloseBody
public abstract ChannelCloseBody createChannelCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
createChannelCloseOkBody
public abstract ChannelCloseOkBody createChannelCloseOkBody()
createChannelFlowBody
public abstract ChannelFlowBody createChannelFlowBody(boolean active)
createChannelFlowOkBody
public abstract ChannelFlowOkBody createChannelFlowOkBody(boolean active)
createChannelOpenBody
public abstract ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)
createConnectionCloseBody
public abstract ConnectionCloseBody createConnectionCloseBody(int replyCode,
AMQShortString replyText,
int classId,
int methodId)
createConnectionCloseOkBody
public abstract ConnectionCloseOkBody createConnectionCloseOkBody()
createConnectionOpenBody
public abstract ConnectionOpenBody createConnectionOpenBody(AMQShortString virtualHost,
AMQShortString capabilities,
boolean insist)
createConnectionOpenOkBody
public abstract ConnectionOpenOkBody createConnectionOpenOkBody(AMQShortString knownHosts)
createConnectionSecureBody
public abstract ConnectionSecureBody createConnectionSecureBody(byte[] challenge)
createConnectionSecureOkBody
public abstract ConnectionSecureOkBody createConnectionSecureOkBody(byte[] response)
createConnectionStartBody
public abstract ConnectionStartBody createConnectionStartBody(short versionMajor,
short versionMinor,
FieldTable serverProperties,
byte[] mechanisms,
byte[] locales)
createConnectionStartOkBody
public abstract ConnectionStartOkBody createConnectionStartOkBody(FieldTable clientProperties,
AMQShortString mechanism,
byte[] response,
AMQShortString locale)
createConnectionTuneBody
public abstract ConnectionTuneBody createConnectionTuneBody(int channelMax,
long frameMax,
int heartbeat)
createConnectionTuneOkBody
public abstract ConnectionTuneOkBody createConnectionTuneOkBody(int channelMax,
long frameMax,
int heartbeat)
createExchangeBoundBody
public abstract ExchangeBoundBody createExchangeBoundBody(AMQShortString exchange,
AMQShortString routingKey,
AMQShortString queue)
createExchangeBoundOkBody
public abstract ExchangeBoundOkBody createExchangeBoundOkBody(int replyCode,
AMQShortString replyText)
createExchangeDeclareBody
public abstract ExchangeDeclareBody createExchangeDeclareBody(int ticket,
AMQShortString exchange,
AMQShortString type,
boolean passive,
boolean durable,
boolean autoDelete,
boolean internal,
boolean nowait,
FieldTable arguments)
createExchangeDeclareOkBody
public abstract ExchangeDeclareOkBody createExchangeDeclareOkBody()
createExchangeDeleteBody
public abstract ExchangeDeleteBody createExchangeDeleteBody(int ticket,
AMQShortString exchange,
boolean ifUnused,
boolean nowait)
createExchangeDeleteOkBody
public abstract ExchangeDeleteOkBody createExchangeDeleteOkBody()
createQueueBindBody
public abstract QueueBindBody createQueueBindBody(int ticket,
AMQShortString queue,
AMQShortString exchange,
AMQShortString routingKey,
boolean nowait,
FieldTable arguments)
createQueueBindOkBody
public abstract QueueBindOkBody createQueueBindOkBody()
createQueueDeclareBody
public abstract QueueDeclareBody createQueueDeclareBody(int ticket,
AMQShortString queue,
boolean passive,
boolean durable,
boolean exclusive,
boolean autoDelete,
boolean nowait,
FieldTable arguments)
createQueueDeclareOkBody
public abstract QueueDeclareOkBody createQueueDeclareOkBody(AMQShortString queue,
long messageCount,
long consumerCount)
createQueueDeleteBody
public abstract QueueDeleteBody createQueueDeleteBody(int ticket,
AMQShortString queue,
boolean ifUnused,
boolean ifEmpty,
boolean nowait)
createQueueDeleteOkBody
public abstract QueueDeleteOkBody createQueueDeleteOkBody(long messageCount)
createQueuePurgeBody
public abstract QueuePurgeBody createQueuePurgeBody(int ticket,
AMQShortString queue,
boolean nowait)
createQueuePurgeOkBody
public abstract QueuePurgeOkBody createQueuePurgeOkBody(long messageCount)
createTxCommitBody
public abstract TxCommitBody createTxCommitBody()
createTxCommitOkBody
public abstract TxCommitOkBody createTxCommitOkBody()
createTxRollbackBody
public abstract TxRollbackBody createTxRollbackBody()
createTxRollbackOkBody
public abstract TxRollbackOkBody createTxRollbackOkBody()
createTxSelectBody
public abstract TxSelectBody createTxSelectBody()
createTxSelectOkBody
public abstract TxSelectOkBody createTxSelectOkBody()
getProtocolVersionMethodConverter
public abstract ProtocolVersionMethodConverter getProtocolVersionMethodConverter()
Licensed to the Apache Software Foundation