AMQPChannel
Properties
A deferred that completes when the channek is closed.
A flow of closed responses from the channel.
A flow of basic delivery messages.
True when the channel is in confirm mode.
A flow of opened responses from the channel.
A flow of basic publish confirm responses.
A flow of basic return responses.
The channel connection state.
Functions
Cancel sending messages from server to consumer.
Consume messages from a queue by sending them to the channel. The consumer is automatically canceled when the channel is closed.
Consume messages from a queue by sending them to registered consume listeners. The caller is responsible for cancelling the consumer when done.
Get a single message from a queue.
Get a single message using a FetchedMessage instance.
Get a single message using a FetchedMessageBuilder block.
Publish a ByteArray message to exchange or queue.
Publish a ByteArray message using a PublishedMessage instance.
Publish a ByteArray message using a PublishedMessageBuilder block.
Sets a prefetch limit when consuming messages. No more messages will be delivered to the consumer until one or more messages have been acknowledged or rejected.
Declares QoS settings using a DeclaredQos instance.
Declares QoS settings using a DeclaredQosBuilder block.
Tell the broker what to do with all unacknowledged messages. Unacknowledged messages retrieved by basicGet are requeued regardless.
Recover unacknowledged messages using a RecoveredMessages instance.
Recover unacknowledged messages using a RecoveredMessagesBuilder block.
Reject a message.
Closes the channel.
Set channel in publish confirm mode, each published message will be acked or nacked.
Set channel in publish confirm mode using a SelectedConfirmMode instance.
Set channel in publish confirm mode using a SelectedConfirmModeBuilder block.
Returns the number of consumers subscribed to a queue.
Bind an exchange to another exchange.
Binds an exchange using a BoundExchange instance.
Binds an exchange using a BoundExchangeBuilder block.
Declare an exchange.
Declares an exchange using a DeclaredExchange instance.
Declares an exchange using a DeclaredExchangeBuilder block.
Passively declare an exchange.
Passively declares an exchange using a DeclaredPassiveExchange instance.
Passively declares an exchange using a DeclaredPassiveExchangeBuilder block.
Delete an exchange.
Deletes an exchange using a DeletedExchange instance.
Deletes an exchange using a DeletedExchangeBuilder block.
Unbind an exchange from another exchange.
Unbinds an exchange using a UnboundExchange instance.
Unbinds an exchange using a UnboundExchangeBuilder block.
Send a flow message to broker to start or stop sending messages to consumers. Warning: Not supported by all brokers.
Send a flow message to broker using a ControlledFlow instance.
Send a flow message to broker using a ControlledFlowBuilder block.
Returns the number of messages in a queue.
Opens the channel.
Binds a queue using a BoundQueue instance.
Binds a queue using a BoundQueueBuilder block.
Declare a server-named exclusive, autodelete, non-durable queue.
Declares a queue.
Declares a queue using a DeclaredQueue instance.
Declares a queue using a DeclaredQueueBuilder block.
Passively declares a queue.
Passively declares a queue using a DeclaredPassiveQueue instance.
Passively declares a queue using a DeclaredPassiveQueueBuilder block.
Deletes a queue.
Deletes a queue using a DeletedQueue instance.
Deletes a queue using a DeletedQueueBuilder block.
Deletes all messages from a queue.
Purges a queue using a PurgedQueue instance.
Purges a queue using a PurgedQueueBuilder block.
Unbinds a queue from an exchange.
Unbinds a queue using a UnboundQueue instance.
Unbinds a queue using a UnboundQueueBuilder block.
Commit a transaction.
Commit a transaction using a CommittedTransaction instance.
Commit a transaction using a CommittedTransactionBuilder block.
Rollback a transaction.
Rollback a transaction using a RolledbackTransaction instance.
Rollback a transaction using a RolledbackTransactionBuilder block.
Set channel in transaction mode.
Set channel in transaction mode using a SelectedTransactionMode instance.
Set channel in transaction mode using a SelectedTransactionModeBuilder block.