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