pico-rabbitmq

RabbitMQ pub-sub for the pico ecosystem: @consumer methods and declarative @publisher clients over aio-pika. Covers what pico-celery does not: events, fan-out, topic routing.

Installation

pip install pico-rabbitmq

Quick start

rabbitmq:
  url: amqp://guest:guest@rabbit.internal/

Consume — a component method per queue, JSON body decoded for you:

from pico_ioc import component
from pico_rabbitmq import consumer

@component
class OrderProjections:
    @consumer("orders-projection", exchange="events", routing_key="orders.*")
    async def on_order_event(self, message: dict):
        ...

Publish — stubs, like a pico-httpx client:

from pico_rabbitmq import publisher, publish

@publisher
class OrderEvents:
    @publish(exchange="events", routing_key="orders.created")
    def order_created(self, message): ...

Semantics:

• Consumers and publishers run on a dedicated background loop — works in sync scripts, FastAPI apps and workers alike, no lifespan wiring.
• Each message resolves its component through the container (prototype scope = fresh instance per message).
• Ack on success; on exception the message is logged and rejected without requeue (configure a dead-letter exchange to keep failures).
• Sync publish stubs block until the broker confirms; async stubs await it.
• Queues and named exchanges are declared durable; the connection closes on container shutdown.

Documentation

Full documentation: https://dperezcabrera.github.io/pico-rabbitmq/

Built for AI-assisted development

pico-rabbitmq is part of an ecosystem designed for humans and coding agents building software together. Every package ships AGENTS.md working conventions, an llms.txt machine-readable docs index and documented behaviour pinned by regression tests; pico-testing gives agents a verification loop for their own changes, and releases are gated by the whole ecosystem booting together against real infrastructure. The full story: Built for AI-assisted development.

Install the agent skills for Claude Code or OpenAI Codex:

curl -sL https://raw.githubusercontent.com/dperezcabrera/pico-skills/main/install.sh | bash

The pico-conventions skill teaches the assistant this module's API surface and invariants; /add-component and /add-tests scaffold components and tests that use it.

License

MIT