OctopusMQ

OctopusMQ is a distributed message queue and key-value store designed for mission-critical systems that demand high availability, strong consistency, and predictable performance. Built on a consensus-based replication protocol, it ensures that no message is ever lost — even during node failures or network partitions.

By combining queue and storage capabilities in a single system, OctopusMQ reduces infrastructure complexity while delivering the reliability and throughput needed for large-scale, real-time workloads such as smart grid management, IoT device orchestration, and industrial data processing.

• Priority message queue - Up to 32 priority levels with built-in starvation prevention, ensuring that lower-priority messages are eventually delivered even under heavy load
• Key-based message grouping - Related messages are automatically delivered together to the same consumer, guaranteeing ordered processing for correlated workflows such as device command sequences
• Distributed key-value store - A fully replicated key-value store with TTL support and exclusive key locking, sharing the same high-availability infrastructure as the message queue
• At-least-once delivery - Messages pulled by a consumer are automatically requeued if the consumer disconnects without acknowledging, preventing message loss without manual intervention
• Unique key deduplication - Ensures only the latest message with a given identifier exists in the queue, ideal for state-update patterns where only the most recent value matters
• High availability - Consensus-based replication across multiple nodes ensures continuous operation and automatic leader election during failures
• Kubernetes-native - Deep integration with Kubernetes StatefulSets for automatic cluster membership management, leader-aware routing, and graceful scaling
• Batch operations - Optimized batch push and pull operations for high-throughput scenarios

OctopusMQ combines the functionality of a message queue and a key-value store into a single, highly-available system.

Its unique key-grouping capability makes it particularly well-suited for scenarios where related messages must be processed together by the same consumer — a pattern common in device management, job orchestration, and distributed task processing.

Kubernetes-native deployment ensures seamless operation in modern cloud environments with minimal operational overhead.