org.apache.qpid.framing
Interface AMQMethodFactory
public interface AMQMethodFactory
Method Summary |
AccessRequestBody |
createAccessRequest(boolean active,
boolean exclusive,
boolean passive,
boolean read,
AMQShortString realm,
boolean write)
|
AMQMethodBody |
createAcknowledge(long deliveryTag,
boolean multiple)
|
ChannelCloseBody |
createChannelClose(int replyCode,
AMQShortString replyText)
|
ChannelFlowBody |
createChannelFlow(boolean active)
|
ChannelOpenBody |
createChannelOpen()
|
ConnectionCloseBody |
createConnectionClose()
|
AMQMethodBody |
createConsumer(AMQShortString tag,
AMQShortString queueName,
FieldTable arguments,
boolean noAck,
boolean exclusive,
boolean noLocal,
int ticket)
|
AMQMethodBody |
createConsumerCancel(AMQShortString consumerTag)
|
ExchangeBoundBody |
createExchangeBound(AMQShortString exchangeName,
AMQShortString queueName,
AMQShortString routingKey)
|
ExchangeDeclareBody |
createExchangeDeclare(AMQShortString name,
AMQShortString type,
int ticket)
|
AMQMethodBody |
createMessageQos(int prefetchCount,
int prefetchSize)
|
QueueBindBody |
createQueueBind(AMQShortString queueName,
AMQShortString exchangeName,
AMQShortString routingKey,
FieldTable arguments,
int ticket)
|
QueueDeclareBody |
createQueueDeclare(AMQShortString name,
FieldTable arguments,
boolean autoDelete,
boolean durable,
boolean exclusive,
boolean passive,
int ticket)
|
QueueDeleteBody |
createQueueDelete(AMQShortString queueName,
boolean ifEmpty,
boolean ifUnused,
int ticket)
|
AMQMethodBody |
createRecover(boolean requeue)
|
AMQMethodBody |
createRejectBody(long deliveryTag,
boolean requeue)
|
TxCommitBody |
createTxCommit()
|
TxRollbackBody |
createTxRollback()
|
TxSelectBody |
createTxSelect()
|
createConnectionClose
ConnectionCloseBody createConnectionClose()
createAccessRequest
AccessRequestBody createAccessRequest(boolean active,
boolean exclusive,
boolean passive,
boolean read,
AMQShortString realm,
boolean write)
createTxSelect
TxSelectBody createTxSelect()
createTxCommit
TxCommitBody createTxCommit()
createTxRollback
TxRollbackBody createTxRollback()
createChannelOpen
ChannelOpenBody createChannelOpen()
createChannelClose
ChannelCloseBody createChannelClose(int replyCode,
AMQShortString replyText)
createChannelFlow
ChannelFlowBody createChannelFlow(boolean active)
createExchangeBound
ExchangeBoundBody createExchangeBound(AMQShortString exchangeName,
AMQShortString queueName,
AMQShortString routingKey)
createExchangeDeclare
ExchangeDeclareBody createExchangeDeclare(AMQShortString name,
AMQShortString type,
int ticket)
createQueueDeclare
QueueDeclareBody createQueueDeclare(AMQShortString name,
FieldTable arguments,
boolean autoDelete,
boolean durable,
boolean exclusive,
boolean passive,
int ticket)
createQueueBind
QueueBindBody createQueueBind(AMQShortString queueName,
AMQShortString exchangeName,
AMQShortString routingKey,
FieldTable arguments,
int ticket)
createQueueDelete
QueueDeleteBody createQueueDelete(AMQShortString queueName,
boolean ifEmpty,
boolean ifUnused,
int ticket)
createRecover
AMQMethodBody createRecover(boolean requeue)
createConsumer
AMQMethodBody createConsumer(AMQShortString tag,
AMQShortString queueName,
FieldTable arguments,
boolean noAck,
boolean exclusive,
boolean noLocal,
int ticket)
createConsumerCancel
AMQMethodBody createConsumerCancel(AMQShortString consumerTag)
createAcknowledge
AMQMethodBody createAcknowledge(long deliveryTag,
boolean multiple)
createRejectBody
AMQMethodBody createRejectBody(long deliveryTag,
boolean requeue)
createMessageQos
AMQMethodBody createMessageQos(int prefetchCount,
int prefetchSize)
Licensed to the Apache Software Foundation