Class | AMQ::Client::Async::Channel |
In: |
lib/amq/client/async/extensions/rabbitmq/confirm.rb
lib/amq/client/async/extensions/rabbitmq/basic.rb lib/amq/client/async/channel.rb |
Parent: | Object |
DEFAULT_REPLY_TEXT | = | "Goodbye".freeze | API | |
RECOVERY_EVENTS | = | [:after_connection_interruption, :before_recovery, :after_recovery].freeze |
consumers_awaiting_cancel_ok | [R] | |
consumers_awaiting_consume_ok | [R] | |
exchanges_awaiting_declare_ok | [R] | |
exchanges_awaiting_delete_ok | [R] | |
flow_is_active | [RW] | |
id | [R] | |
queues_awaiting_bind_ok | [R] | |
queues_awaiting_declare_ok | [R] | |
queues_awaiting_delete_ok | [R] | |
queues_awaiting_get_response | [R] | |
queues_awaiting_purge_ok | [R] | |
queues_awaiting_unbind_ok | [R] |
Acknowledge one or all messages on the channel.
@api public @see bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.13.)
Called by associated connection object when AMQP connection has been re-established (for example, after a network failure).
@api plugin
Defines a callback that will be executed after TCP connection has recovered after a network failure but before AMQP connection is re-opened. Only one callback can be defined (the one defined last replaces previously added ones).
@api public
AMQP connection this channel belongs to.
@return [AMQ::Client::Connection] Connection this channel belongs to.
Asks the peer to pause or restart the flow of content data sent to a consumer. This is a simple flowcontrol mechanism that a peer can use to avoid overflowing its queues or otherwise finding itself receiving more messages than it can process. Note that this method is not intended for window control. It does not affect contents returned to Queue#get callers.
@param [Boolean] active Desired flow state.
@see bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.5.2.3.) @api public
Defines a callback that will be executed after TCP connection is interrupted (typically because of a network failure). Only one callback can be defined (the one defined last replaces previously added ones).
@api public
Defines a callback that will be executed when channel is closed after channel-level exception.
@api public
Defines a callback that will be executed after AMQP connection has recovered after a network failure. Only one callback can be defined (the one defined last replaces previously added ones).
@api public
Requests a specific quality of service. The QoS can be specified for the current channel or for all channels on the connection.
@note RabbitMQ as of 2.3.1 does not support prefetch_size. @api public
Notifies AMQ broker that consumer has recovered and unacknowledged messages need to be redelivered.
@return [Channel] self
@note RabbitMQ as of 2.3.1 does not support basic.recover with requeue = false. @see bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.16.) @api public
Reject a message with given delivery tag.
@api public @see bit.ly/amqp091reference AMQP 0.9.1 protocol reference (Section 1.8.3.14.)
Sets the channel to use standard transactions. One must use this method at least once on a channel before using tx_tommit or tx_rollback methods.
@api public