Class AMQ::Client::Async::Consumer
In: lib/amq/client/async/consumer.rb
Parent: Object

Methods

Included Modules

Async::Callbacks

Attributes

arguments  [R] 
channel  [R]  API
consumer_tag  [R] 
queue  [R] 

Public Class methods

Public Instance methods

Acknowledge a delivery tag. @return [Consumer] self

@api public @see bit.ly/htCzCX AMQP 0.9.1 protocol documentation (Section 1.8.3.13.)

after_connection_interruption(&block)
after_recovery(&block)

Alias for on_recovery

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 is 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

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 AMQP connection is recovered after a network failure.. Only one callback can be defined (the one defined last replaces previously added ones).

@api public

@return [Consumer] self

@api public @see bit.ly/htCzCX AMQP 0.9.1 protocol documentation (Section 1.8.3.14.)

Used by automatic recovery code. @api plugin

Protected Instance methods

[Validate]