initial commit

Author: RivanDev

Diff for: .gitignore

@@ -0,0 +1,3 @@
+.idea
+.venv
+.env

Diff for: compose.yaml

@@ -0,0 +1,6 @@
+version: "3.8"
+services:
+  rabbitmq:
+    image: rabbitmq:3.10.7-management
+    ports:
+      - 5672:5672

Diff for: poetry.lock

@@ -0,0 +1,16 @@
+[tool.poetry]
+name = "tutorial-aiopika"
+version = "0.1.0"
+description = ""
+authors = ["Your Name <[email protected]>"]
+readme = "README.md"
+packages = [{include = "tutorial_aiopika"}]
+
+[tool.poetry.dependencies]
+python = "^3.11"
+aio-pika = "^9.4.0"
+
+
+[build-system]
+requires = ["poetry-core"]
+build-backend = "poetry.core.masonry.api"

Diff for: pyproject.toml

@@ -0,0 +1,26 @@
+import asyncio
+
+from aio_pika import connect
+from aio_pika.abc import AbstractIncomingMessage
+
+
+async def on_message(message: AbstractIncomingMessage) -> None:
+    print(" [x] Received message %r" % message)
+    print("Message body is: %r" % message.body)
+
+    print("Before sleep!")
+    await asyncio.sleep(5)
+    print("After sleep!")
+
+async def main() -> None:
+    connection = await connect("amqp://guest:guest@localhost/")
+    async with connection:
+        channel = await connection.channel()
+        queue = await channel.declare_queue("hello")
+        await queue.consume(on_message, no_ack=True)
+        print(" [x] Waiting for messages. To exit press CTRL + C")
+        await asyncio.Future()
+
+if __name__ == '__main__':
+    asyncio.run(main())
+

Diff for: receive.py

@@ -0,0 +1,22 @@
+import asyncio
+
+from aio_pika import Message, connect
+
+
+async def main() -> None:
+    connection = await connect("amqp://guest:guest@localhost/")
+
+    async with connection:
+        channel = await connection.channel()
+
+        queue = await channel.declare_queue("hello")
+
+        await channel.default_exchange.publish(
+            Message(b"Hello World!"),
+            routing_key=queue.name,
+        )
+
+        print(" [x] Sent ' HELLO WORLD!'")
+
+if __name__ == '__main__':
+    asyncio.run(main())