broccoli

Broccoli

A robust message queue system for Rust applications, designed as a Rust alternative to Celery. Currently Redis-backed, with planned support for RabbitMQ, Kafka, and other message brokers. This is by no means a finished product, but we're actively working on it and would love your feedback and contributions!

Features

• Asynchronous message processing
• Redis-backed persistence (with RabbitMQ and Kafka support planned)
• Configurable retry strategies
• Connection pooling
• Type-safe message handling
• Error handling with custom handlers
• Flexible message processing patterns

Installation

Add this to your Cargo.toml:

[dependencies]
broccoli_queue = "0.1.0"

Quick Start

Producer

…

Consumer

…

Why Broccoli?

If you're familiar with Celery but want to leverage Rust's performance and type safety, Broccoli is your answer. While currently focused on Redis as the message broker, we're actively working on supporting multiple brokers to provide the same flexibility as Celery:

• Redis (Current)
• RabbitMQ (Planned)
• Kafka (Planned)
• And more to come!

This multi-broker approach will allow you to choose the message broker that best fits your needs while maintaining a consistent API.

Documentation

• API Documentation

Roadmap

• Redis broker implementation
• RabbitMQ broker support
• Kafka broker support
• Proc macros for building workers
• Additional message patterns
• Enhanced monitoring and metrics
• Web interface for job monitoring

License

MIT License

Contributing

Contributions are welcome! Please feel free to submit a Pull Request. We're particularly interested in contributions for:

• New broker implementations
• Additional message patterns
• Performance improvements
• Documentation enhancements
• Bug fixes