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 configurable priority levels for fine-grained control over delivery order, so that urgent work is always handled first.
• 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.
• Time-to-live everywhere - Automatic expiration of both queued messages and stored values keeps data fresh and self-cleaning, with no manual housekeeping.
• Operational control - Create, resize, pause, and resume queues, and adjust cluster membership without downtime.
• Command-line management - A dedicated CLI manages queues and key-value stores, inspects state, and runs data operations across multiple environments, with per-context TLS — available for Linux, macOS, and Windows.
• Secure by design - TLS-secured client connections and hardened containers that run as a non-root user with a read-only filesystem and minimal privileges, shipped with a Software Bill of Materials for supply-chain transparency.
• Built-in observability - Native Prometheus metrics and OpenTelemetry tracing, plus Kubernetes liveness, readiness, and startup probes for seamless integration into modern monitoring stacks.

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. Paired with its command-line tool, built-in observability, and hardened, security-first containers, OctopusMQ is straightforward to operate and monitor in production.