QueenMQ

About

An open-source message broker written in Rust, shipped as a single binary with Raft-replicated storage. Each entity such as a customer or conversation gets its own dynamic partition, so one slow consumer does not block others, which addresses head-of-line blocking seen when slow LLM calls share Kafka partitions. Each step commits the acknowledgment, next message, state and timer together.