benzene-rabbitmq

Host Benzene Python handlers on RabbitMQ — a self-hosted consumer and a RabbitMQ-publish outbound client — the same handlers, no rewrite. Depends only on benzene-core.

pip install benzene-rabbitmq               # the binding + testing helpers
pip install "benzene-rabbitmq[rabbitmq]"   # + pika for the real clients

from benzene.core import application_from, build_application
from benzene.rabbitmq import RabbitMqConsumerApp, RabbitMqMessageSender, run_consumer_loop

# Inbound: one delivery -> one pipeline invocation -> one scope; ack/log, no reply.
definition, _ = build_application(OrdersStartUp)
app = RabbitMqConsumerApp(application_from(definition))
await run_consumer_loop(app, channel, queue="orders")  # channel: a pika channel

# Outbound: publish to an exchange, Benzene topic carried in the `topic` header.
sender = RabbitMqMessageSender("orders-events", host="localhost")
await sender.send_message("orders:created", order, headers={"x-correlation-id": "abc"})

• Consumer — the Benzene topic comes from the topic header carried in the delivery's AMQP properties.headers (the cross-port convention); the other headers are the Benzene headers (UTF-8), the body is the JSON body. One delivery is one scope; there is no response channel, so the result is acknowledge/log only — run_consumer_loop acks the delivery on success (at-least-once) and nacks a failed one for redelivery. A poison delivery can never crash the loop.
• Outbound — RabbitMqMessageSender implements the benzene.core.MessageSender port over pika (optional extra), forwarding the header dictionary onto the AMQP properties.headers so correlation/trace propagation rides across the hop.

The binding is duck-typed against pika, so decode, dispatch, and publish are exercised in memory with fakes — no broker, no SDK. Test through benzene.rabbitmq.testing (a native-delivery builder + a test host) or the shared harness (create_test_host(StartUp).build_rabbitmq() + send_rabbitmq) — see the runnable examples/rabbitmq_orders/. Mirrors .NET's Benzene.RabbitMq, and contributes the benzene.rabbitmq subpackage to the shared benzene namespace.