Introduction #

CometMQ is a high-performance AMQP 0.9.1 message broker designed for durability, observability, and operational simplicity.

Why CometMQ? #

• High Performance: Efficient core focused on low latency and throughput
• AMQP 0.9.1 Compatible: Drop-in replacement for RabbitMQ protocol
• Durable Storage: Journal-based WAL with partial compaction
• Flow Control: Memory and disk watermarks with connection blocking
• Real-time Metrics: Prometheus integration out of the box
• Simple Operations: Single binary, YAML configuration

Key Features #

Core Messaging #

• Direct, fanout, topic, and headers exchanges
• Durable and priority queues
• Publisher confirms and consumer acknowledgments
• Dead letter exchanges (DLX) with retry logic

Durability #

• Write-ahead log (WAL) with configurable fsync policies
• Partial compaction for space reclamation
• Quota management (block/reject/DLX policies)

Observability #

• Prometheus metrics endpoint
• Structured logging (JSON/plain)
• Admin HTTP API for runtime inspection

Security #

• TLS support for AMQP and Admin API
• SASL PLAIN and EXTERNAL authentication
• Per-vhost regex-based ACL

Architecture #

CometMQ uses a journal-based storage system with segment rotation and partial compaction. Messages are stored in memory-mapped segments with periodic fsync based on configurable policies (always, every_n, interval_ms).

Flow control is implemented at both memory and disk levels, with hysteresis watermarks to prevent oscillation.

Getting Started #

Ready to try CometMQ? Head to the Quick Start guide.

Resources #

• Feature Matrix - Capability overview
• EULA - End User License Agreement