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()
           
 

Method Detail

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