# File lib/amq/client/async/consumer.rb, line 209 def handle_consume_ok(consume_ok) self.exec_callback_once(:consume, consume_ok) end