aio_pika_rabbitmq_async_queue_send_receive_quickstart.py

1import asyncio
2import aio_pika
3
4async def main() -> None:
5    # Connection string
6    connection = await aio_pika.connect_robust(
7        "amqp://guest:guest@127.0.0.1/",
8    )
9
10    async with connection:
11        # Creating a channel
12        channel = await connection.channel()
13
14        # Declaring a queue
15        queue = await channel.declare_queue("test_queue")
16
17        # Sending a message
18        await channel.default_exchange.publish(
19            aio_pika.Message(body="Hello World!".encode()),
20            routing_key="test_queue",
21        )
22
23        # Receiving a message
24        incoming_message = await queue.get()
25
26        async with incoming_message.process():
27            print(f" [x] Received message: {incoming_message.body!r}")
28
29
30if __name__ == "__main__":
31    asyncio.run(main())