Lightweight asyncio compatible utilities for consuming broker messages.

import asyncio

from aio_message_handler.consumer import Consumer


async def main():
    consumer = Consumer("amqp://guest:[email protected]/")

    @consumer.message_handler(exchange="myexchange", binding_key="key")
    async def handler(msg):
        print('received:', msg.body)
        msg.ack()
    
    await consumer.start()

asyncio.run(main())