Simple pub/sub sample using rabbitmq. To run python scripts, just run `uv run sub.py`

docker-compose.yaml

version: "3.9"

services:
  rabbitmq:
    image: rabbitmq:3-management
    container_name: rabbitmq
    ports:
      - 5672:5672
      - 15672:15672

pub.py

# /// script
# dependencies = [
#   "pika",
# ]
# ///

import pika

connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
channel = connection.channel()

# channel.exchange_declare(exchange='amq.fanout', exchange_type='fanout')

print("write a message ('quit' to exit)")
message = None

while message != "quit":
    message = input()
    channel.basic_publish(exchange="amq.fanout", routing_key="my.poc", body=message)
    print(f" [x] Sent: {message}")

connection.close()
print("exiting publisher!")

sub.py

# /// script
# dependencies = [
#   "pika",
# ]
# ///

import pika
import random
import string

connection = pika.BlockingConnection(pika.ConnectionParameters(host="localhost"))
channel = connection.channel()

# channel.exchange_declare(exchange='amq.fanout', exchange_type='fanout')

suffix = "".join(random.choices(string.ascii_uppercase + string.digits, k=5))
queue_name = f"my.poc.{suffix}"
result = channel.queue_declare(queue=queue_name, exclusive=True)

channel.queue_bind(exchange="amq.fanout", queue=queue_name)

print(" [*] Waiting for messages. To exit press CTRL+C")


def callback(ch, method, properties, body):
    print(f" [x] {body}")


channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=True)

channel.start_consuming()