Method: AMQ::Client::Async::Queue#auto_recover

Defined in:
lib/amq/client/async/queue.rb

#auto_recover ⇒ Object

Called by associated connection object when AMQP connection has been re-established (for example, after a network failure).



427
428
429
430
431
432
433
434
435
436
 
# File 'lib/amq/client/async/queue.rb', line 427

def auto_recover
  self.exec_callback_yielding_self(:before_recovery)
  self.redeclare do
    self.rebind

    @consumers.each { |tag, consumer| consumer.auto_recover }

    self.exec_callback_yielding_self(:after_recovery)
  end
end