🔌
Connection Pool
Efficiently manages AMQP connections using deadpool for optimal resource utilization and performance.
🚀 Now supporting Go and Rust
Easy RMQ
Modern AMQP libraries for Rust and Go with connection pool, publisher, and subscriber. Build reliable distributed systems with minimal boilerplate.
Production-Ready Features
Everything you need to build reliable message-driven applications.
⚙️
Auto Setup
Automatically creates exchanges, queues, and bindings - no manual infrastructure needed.
🔄
Retry Mechanism
Automatic retry with configurable delays and dead letter queue for failed messages.
🔍
Distributed Tracing
Built-in trace ID generation with OpenTelemetry support for tracking message flows.
📋
Worker Registry
Register and manage multiple workers with a clean, consistent pattern for message handling.
🎯
Single Active Consumer
Ensure only one consumer processes messages at a time for strict ordering requirements.
⚡
Concurrency Control
Configurable worker concurrency with async/blocking spawn options for optimal throughput.
🔧
Middleware Support
Custom middleware for logging, metrics, distributed tracing, and more.
Ready to scale your messaging?
Join thousands of developers building resilient microservices with Easy RMQ.