faststream-outbox

Welcome to the faststream-outbox documentation!

faststream-outbox is a FastStream broker integration for the transactional outbox pattern — a Postgres table is the message queue.

A producer writes a domain entity and an outbox row in the same SQLAlchemy transaction. A subscriber polls the table with FOR UPDATE SKIP LOCKED, runs the handler, and deletes the row on success. No separate message bus, no relay process — the table is the queue.

---

• Installation
• How it works
• Basic usage
• Subscriber
• Dead-letter queue
• Publisher
• Router
• FastAPI integration
• Timers
• Testing
• Schema validation
• Observability