AMQP implementation using asyncio