Pynenc RabbitMQ Plugin

RabbitMQ broker for Pynenc distributed task orchestration.

The pynenc-rabbitmq plugin adds a durable, persistent RabbitMQ message broker to Pynenc. Since RabbitMQ only covers brokering, pair it with the Redis or MongoDB plugin for the full Pynenc stack.

pip install pynenc-rabbitmq

Component

Component	Class	Role
Broker	RabbitMqBroker	Persistent FIFO queue with publisher confirms and automatic retries

---

Quick Start

RabbitMQ only covers brokering — pair it with Redis or MongoDB for the rest:

from pynenc import PynencBuilder

app = (
    PynencBuilder()
    .app_id("my_app")
    .redis(url="redis://localhost:6379")      # state, orchestrator, trigger
    .rabbitmq_broker(host="localhost")         # swap broker to RabbitMQ
    .process_runner()
    .build()
)

@app.task
def add(x: int, y: int) -> int:
    return x + y

See Installation & Quick Start for a MongoDB variant and Docker Compose examples.

---

🚀 Installation & Quick Start

Combine RabbitMQ with Redis or MongoDB state backends. Includes PynencBuilder examples and Docker Compose.

Installation & Quick Start

⚙️ Configuration Reference

All connection, queue, exchange, consumer, retry, and pika logging settings — with types and defaults.

Configuration Reference

🏗️ Architecture

Thread-safe connections, message persistence, automatic retries, and queue naming strategy.

Architecture

---

Part of the Pynenc ecosystem · Redis Plugin · MongoDB Plugin