Method: AMQ::Client::Async::Consumer#handle_consume_ok

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

#handle_consume_ok(consume_ok) ⇒ Object

handle_delivery(basic_deliver, metadata, payload)



209
210
211
 
# File 'lib/amq/client/async/consumer.rb', line 209

def handle_consume_ok(consume_ok)
  self.exec_callback_once(:consume, consume_ok)
end