Method: AMQ::Client::Async::Consumer#before_recovery

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

#before_recovery(&block) ⇒ Object

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).



157
158
159
 
# File 'lib/amq/client/async/consumer.rb', line 157

def before_recovery(&block)
  self.redefine_callback(:before_recovery, &block)
end