public final class MethodRegistry extends Object
Constructor and Description |
---|
MethodRegistry(ProtocolVersion pv) |
public MethodRegistry(ProtocolVersion pv)
public void setProtocolVersion(ProtocolVersion protocolVersion)
public final AccessRequestBody createAccessRequestBody(AMQShortString realm, boolean exclusive, boolean passive, boolean active, boolean write, boolean read)
public final AccessRequestOkBody createAccessRequestOkBody(int ticket)
public final BasicQosBody createBasicQosBody(long prefetchSize, int prefetchCount, boolean global)
public final BasicQosOkBody createBasicQosOkBody()
public final BasicConsumeBody createBasicConsumeBody(int ticket, String queue, String consumerTag, boolean noLocal, boolean noAck, boolean exclusive, boolean nowait, Map<String,Object> arguments)
public final BasicConsumeOkBody createBasicConsumeOkBody(AMQShortString consumerTag)
public final BasicCancelBody createBasicCancelBody(AMQShortString consumerTag, boolean nowait)
public final BasicCancelOkBody createBasicCancelOkBody(AMQShortString consumerTag)
public final BasicPublishBody createBasicPublishBody(int ticket, String exchange, String routingKey, boolean mandatory, boolean immediate)
public final BasicReturnBody createBasicReturnBody(int replyCode, AMQShortString replyText, AMQShortString exchange, AMQShortString routingKey)
public final BasicDeliverBody createBasicDeliverBody(AMQShortString consumerTag, long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey)
public final BasicGetBody createBasicGetBody(int ticket, AMQShortString queue, boolean noAck)
public final BasicGetOkBody createBasicGetOkBody(long deliveryTag, boolean redelivered, AMQShortString exchange, AMQShortString routingKey, long messageCount)
public final BasicGetEmptyBody createBasicGetEmptyBody(AMQShortString clusterId)
public final BasicAckBody createBasicAckBody(long deliveryTag, boolean multiple)
public final BasicRejectBody createBasicRejectBody(long deliveryTag, boolean requeue)
public final BasicRecoverBody createBasicRecoverBody(boolean requeue)
public final BasicRecoverSyncOkBody createBasicRecoverSyncOkBody()
public final BasicRecoverSyncBody createBasicRecoverSyncBody(boolean requeue)
public final ChannelAlertBody createChannelAlertBody(int replyCode, AMQShortString replyText, FieldTable details)
public final ChannelOpenBody createChannelOpenBody(AMQShortString outOfBand)
public final ChannelOpenOkBody createChannelOpenOkBody(byte[] channelId)
public final ChannelOpenOkBody createChannelOpenOkBody()
public final ChannelFlowBody createChannelFlowBody(boolean active)
public final ChannelFlowOkBody createChannelFlowOkBody(boolean active)
public final ChannelCloseBody createChannelCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
public final ChannelCloseOkBody createChannelCloseOkBody()
public final ConnectionStartBody createConnectionStartBody(short versionMajor, short versionMinor, FieldTable serverProperties, byte[] mechanisms, byte[] locales)
public final ConnectionStartOkBody createConnectionStartOkBody(FieldTable clientProperties, AMQShortString mechanism, byte[] response, AMQShortString locale)
public final ConnectionSecureBody createConnectionSecureBody(byte[] challenge)
public final ConnectionSecureOkBody createConnectionSecureOkBody(byte[] response)
public final ConnectionTuneBody createConnectionTuneBody(int channelMax, long frameMax, int heartbeat)
public final ConnectionTuneOkBody createConnectionTuneOkBody(int channelMax, long frameMax, int heartbeat)
public final ConnectionOpenBody createConnectionOpenBody(AMQShortString virtualHost, AMQShortString capabilities, boolean insist)
public final ConnectionOpenOkBody createConnectionOpenOkBody(AMQShortString knownHosts)
public final ConnectionRedirectBody createConnectionRedirectBody(AMQShortString host, AMQShortString knownHosts)
public final ConnectionCloseBody createConnectionCloseBody(int replyCode, AMQShortString replyText, int classId, int methodId)
public final ConnectionCloseOkBody createConnectionCloseOkBody()
public final ExchangeDeclareBody createExchangeDeclareBody(int ticket, String exchange, String type, boolean passive, boolean durable, boolean autoDelete, boolean internal, boolean nowait, Map<String,Object> arguments)
public final ExchangeDeclareOkBody createExchangeDeclareOkBody()
public final ExchangeDeleteBody createExchangeDeleteBody(int ticket, String exchange, boolean ifUnused, boolean nowait)
public final ExchangeDeleteOkBody createExchangeDeleteOkBody()
public final ExchangeBoundBody createExchangeBoundBody(String exchange, String routingKey, String queue)
public final ExchangeBoundOkBody createExchangeBoundOkBody(int replyCode, AMQShortString replyText)
public final QueueDeclareBody createQueueDeclareBody(int ticket, String queue, boolean passive, boolean durable, boolean exclusive, boolean autoDelete, boolean nowait, Map<String,Object> arguments)
public final QueueDeclareOkBody createQueueDeclareOkBody(AMQShortString queue, long messageCount, long consumerCount)
public final QueueBindBody createQueueBindBody(int ticket, String queue, String exchange, String routingKey, boolean nowait, Map<String,Object> arguments)
public final QueueBindOkBody createQueueBindOkBody()
public final QueuePurgeBody createQueuePurgeBody(int ticket, AMQShortString queue, boolean nowait)
public final QueuePurgeOkBody createQueuePurgeOkBody(long messageCount)
public final QueueDeleteBody createQueueDeleteBody(int ticket, String queue, boolean ifUnused, boolean ifEmpty, boolean nowait)
public final QueueDeleteOkBody createQueueDeleteOkBody(long messageCount)
public final QueueUnbindBody createQueueUnbindBody(int ticket, AMQShortString queue, AMQShortString exchange, AMQShortString routingKey, FieldTable arguments)
public final QueueUnbindOkBody createQueueUnbindOkBody()
public final TxSelectBody createTxSelectBody()
public final TxSelectOkBody createTxSelectOkBody()
public final TxCommitBody createTxCommitBody()
public final TxCommitOkBody createTxCommitOkBody()
public final TxRollbackBody createTxRollbackBody()
public final TxRollbackOkBody createTxRollbackOkBody()
public ProtocolVersion getProtocolVersion()
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.