Method: AMQ::Client::Async::Consumer#auto_recover

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

#auto_recover ⇒ Object

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



187
188
189
190
191
 
# File 'lib/amq/client/async/consumer.rb', line 187

def auto_recover
  self.exec_callback_yielding_self(:before_recovery)
  self.resubscribe
  self.exec_callback_yielding_self(:after_recovery)
end