class EventMachine::Synchrony::AMQP::Consumer

def on_delivery(&block)
  Fiber.new do
    aon_delivery(&EM::Synchrony::AMQP.sync_cb(Fiber.current))
    loop { block.call(Fiber.yield) }
  end.resume
  self
end