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.
Publish a ByteArray message to exchange or queue.
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.
Tell the broker what to do with all unacknowledged messages. Unacknowledged messages retrieved by basicGet are requeued regardless.
Reject a message.
Closes the channel.
Set channel in publish confirm mode, each published message will be acked or nacked.
Returns the number of consumers subscribed to a queue.
Bind an exchange to another exchange.
Declare an exchange.
Passively declare an exchange.
Delete an exchange.
Unbind an exchange from another exchange.
Send a flow message to broker to start or stop sending messages to consumers. Warning: Not supported by all brokers.
Returns the number of messages in a queue.
Opens the channel.
Declare a server-named exclusive, autodelete, non-durable queue.
Declares a queue.
Passively declares a queue.
Deletes a queue.
Deletes all messages from a queue.
Unbinds a queue from an exchange.
Commit a transaction.
Rollback a transaction.
Set channel in transaction mode.