DefaultAMQPChannel
Constructors
Properties
A deferred that completes when the channel 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.
Called by the connection read loop when the broker closes this channel, before the Channel.Closed event is emitted — so the hook runs before either restore trigger can observe the close. Base channels don't restore, so this is a no-op; RobustAMQPChannel overrides it to arm a one-shot restore token (see its cancelAll).
Opens the channel.
Hook called by writeAndWaitForResponse before acquiring writeMutex. Subclasses can override to perform any waiting that must NOT happen while the mutex is held — e.g. RobustAMQPChannel awaits its restoreCompleted deferred here, because doing so inside the mutex would deadlock against restore's own writes (which need the same mutex).
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.
Determines whether this channel should be removed from the connection's channel registry when the broker closes it. Robust channels override this to return false since they restore.
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.