Multiple readers work asynchronously

read_async_get.py

import asyncio
import aio_pika

async def read(reader_id):
    connection = await aio_pika.connect_robust(**RMQ_CONFIG)
    async with connection:
        channel = await connection.channel()
        queue = await channel.declare_queue('test_queue', durable=True)
        message = await queue.get()
        
        # the difference is here
        while True:
            try:
                message = await queue.get()
                print(reader_id)
                await asyncio.sleep(1)  # emulate async task
            except Exception:
                await asyncio.sleep(1)

if __name__ == '__main__':
    loop = asyncio.get_event_loop()
    readers = [read(i) for i in range(3)]
    loop.run_until_complete(asyncio.wait(readers))