print('consumer {} recved {} ({})'.format(envelope.consumer_tag, body,
    envelope.delivery_tag))

@asyncio.coroutine
def callback(body, envelope, properties):
    loop = asyncio.get_event_loop()
loop.create_task(do_work(envelope, body))

@asyncio.coroutine
def receive_log():
    pass
Asynchronous RabbitMQ consumer with aioamqp