Open-source message-queue software
593 open-source libraries, tools and applications tagged message-queue, ranked by how closely message-queue is their primary purpose, then by adoption and maintenance health. Each entry links to a page with sources, use cases and when to choose or avoid it.
593 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| redis/ioredis ioredis is a robust, performance-focused, full-featured Redis client for Node.js written in TypeScript. It supports Redis Cluster, Sentinel… | 94 | 15343 | maintenance |
| primus/eventemitter3 EventEmitter3 is a high-performance JavaScript event emitter that is API-compatible with Node.js's built-in EventEmitter while also running… | 65 | 3538 | stable |
| olric-data/olric Olric is a distributed, in-memory key/value store and cache written entirely in Go. It can be embedded as a Go library or run as a standalo… | 85 | 3495 | active |
| svix/svix-webhooks Svix is an open-source, enterprise-ready webhooks-as-a-service platform written in Rust that lets developers send webhooks with a single AP… | 96 | 3457 | active |
| Wisper Wisper is a micro library that adds Publish-Subscribe (pub/sub) capabilities to plain Ruby objects. Objects including the Wisper::Publisher… | 32 | 3331 | stable |
| Eclipse Zenoh Zenoh is a Rust-implemented pub/sub/query protocol and library that unifies data in motion, data at rest, and computations with minimal wir… | 97 | 3259 | active |
| bloomberg/blazingmq BlazingMQ is a distributed, high-performance message queuing system written in C++, providing durable, fault-tolerant queues with rich rout… | 73 | 3215 | stable |
| zeromq/netmq NetMQ is a 100% native C# port of the ZeroMQ lightweight messaging library for .NET. It provides asynchronous message-queue sockets support… | 90 | 3180 | active |
| Celery Kombu is a Python messaging library providing an idiomatic high-level interface to the AMQP protocol and pluggable transports for RabbitMQ,… | 84 | 3147 | stable |
| twmb/franz-go franz-go is a feature-complete, pure Go Apache Kafka client library supporting Kafka 0.8.0 through 4.2+, including producing, consuming, tr… | 77 | 3113 | active |
| Nchan Nchan is a scalable pub/sub message server and proxy implemented as an Nginx module, supporting Websocket, EventSource (SSE), long-polling,… | 75 | 3066 | stable |
| EasyNetQ/EasyNetQ EasyNetQ is an easy-to-use .NET client API for RabbitMQ that simplifies pub/sub messaging, delayed scheduling, and RPC over an AMQP broker.… | 95 | 3060 | active |
| bensheldon/good_job GoodJob is a multithreaded, Postgres-based Active Job backend for Ruby on Rails. It stores jobs in Postgres, uses advisory locks and LISTEN… | 100 | 3000 | stable |
| softwaremill/elasticmq ElasticMQ is an in-memory message queue system that implements an Amazon SQS-compatible REST interface. It can run stand-alone (including v… | 86 | 2950 | active |
| LockGit/gochat gochat is a lightweight instant messaging (IM) server written in pure Go, supporting private messages and room broadcast messages with WebS… | 74 | 2934 | active |
| frain-dev/convoy Convoy is an open-source, high-performance webhooks gateway for reliably ingesting, persisting, debugging, and delivering webhook events at… | 95 | 2877 | active |
| benmanns/goworker goworker is a Go library for running Resque-compatible background job workers, consuming jobs from Redis queues pushed by Ruby/Rails Resque… | 75 | 2849 | active |
| postaljs/postal.js postal is a TypeScript-first pub/sub message bus for JavaScript with AMQP-style topic wildcards, channel-scoped messaging, request/response… | 69 | 2834 | active |
| Liftbridge Liftbridge is a lightweight, fault-tolerant message streaming system written in Go that implements a durable, replicated message log on top… | 74 | 2805 | active |
| golevelup/nestjs A monorepo of NestJS modules and utilities from golevelup, including RabbitMQ integration (RPC and pub/sub), Hasura event handlers, Stripe … | 94 | 2749 | active |
| excid3/noticed Noticed is a Ruby gem for sending notifications in Ruby on Rails applications across multiple delivery methods like email, SMS, Slack, and … | 98 | 2705 | active |
| argoproj/argo-events Argo Events is an event-driven workflow automation framework for Kubernetes that triggers actions like creating Kubernetes objects, invokin… | 90 | 2699 | active |
| Broadway Broadway is an Elixir library for building concurrent, multi-stage data ingestion and processing pipelines on top of GenStage. It provides … | 75 | 2689 | stable |
| Rebus Rebus is a lean, free service bus implementation for .NET that provides asynchronous messaging between services following the 'smart endpoi… | 75 | 2667 | stable |
| brandonhilkert/sucker_punch Sucker Punch is a single-process asynchronous background job processing library for Ruby, built on concurrent-ruby. Jobs are stored in memo… | 55 | 2628 | stable |
| nanomq/nanomq NanoMQ is an ultra-lightweight, high-performance MQTT broker and messaging bus written in C for IoT/IIoT edge computing and software-define… | 95 | 2619 | active |
| Eclipse iceoryx iceoryx2 is an ultra-low latency inter-process communication middleware with a Rust core, offering true zero-copy, lock-free messaging via … | 80 | 2592 | active |
| tporadowski/redis An unofficial native Windows port of Redis 5.0.14 (and 4.0.14), the in-memory key-value database with persistence, supporting strings, list… | 66 | 10271 | maintenance |
| eventflow/EventFlow EventFlow is an async/await-first CQRS and event sourcing framework for .NET, built around domain-driven design concepts like aggregates, c… | 78 | 2568 | active |
| lovoo/goka Goka is a compact yet powerful distributed stream processing library for Apache Kafka written in Go. It extends Kafka consumer groups by bi… | 88 | 2548 | active |
| mqant mqant is a concise, high-performance distributed microservice framework written in Go, originally designed for real-time game servers. It p… | 32 | 2515 | active |
| spring-projects/spring-kafka Spring for Apache Kafka (spring-kafka) is a Java library that applies familiar Spring abstractions to Apache Kafka-based messaging. It prov… | 96 | 2514 | stable |
| rails/solid_queue Solid Queue is a database-backed queuing backend for Rails Active Job, storing jobs in SQL databases like MySQL, PostgreSQL, or SQLite. It … | 94 | 2496 | active |
| earendil-works/absurd Absurd is a Postgres-native durable execution (workflow) system that runs long-lived, reliable tasks using only a single SQL schema file an… | 76 | 2486 | active |
| apache/activemq Apache ActiveMQ is a high-performance, multi-protocol, Java-based open source message broker supporting JMS/Jakarta Messaging, AMQP, MQTT, … | 98 | 2464 | stable |
| moquette-io/moquette Moquette is a lightweight MQTT broker written in Java, compliant with MQTT 5 and MQTT 3, supporting QoS 0-2 and most MQTT 5 features. It is… | 81 | 2458 | active |
| birdayz/kaf Kaf is a modern command-line tool for Apache Kafka written in Go, inspired by kubectl and docker. It lets users manage clusters, topics, co… | 67 | 2445 | active |
| eclipse-paho/paho.mqtt.python The Eclipse Paho MQTT Python client library implementing MQTT protocol versions 5.0, 3.1.1, and 3.1. It enables Python applications to conn… | 67 | 2429 | active |
| graphile/worker Graphile Worker is a high-performance job queue for PostgreSQL that runs background jobs on Node.js, supporting retries with exponential ba… | 86 | 2410 | active |
| Wolverine Wolverine is a next-generation .NET mediator and message bus framework for building robust event-driven server-side applications. It provid… | 96 | 2386 | active |
| dashersw/cote cote is a Node.js library for building zero-configuration microservices with automatic service discovery. It provides Responder/Requester, … | 57 | 2386 | stable |
| AnyCable AnyCable is an open-source realtime server written in Go that provides reliable two-way communication over WebSockets and SSE with built-in… | 97 | 2384 | stable |
| syslog-ng/syslog-ng syslog-ng is an enhanced syslog daemon that collects, parses, filters, and routes log messages from a wide range of sources including syslo… | 88 | 2377 | stable |
| taskiq Taskiq is an asynchronous distributed task queue for Python, inspired by Celery and Dramatiq. It lets you define tasks as decorated functio… | 97 | 2345 | active |
| anthdm/hollywood Hollywood is a fast, lightweight actor model engine for Go, supporting local and clustered distributed actors with guaranteed message deliv… | 68 | 2341 | active |
| que-rb/que Que is a Ruby job queue backed by PostgreSQL that uses advisory locks for high-throughput, reliable background job processing. Jobs are sto… | 65 | 2326 | active |
| poundifdef/smoothmq SmoothMQ is a drop-in replacement for Amazon SQS that runs as a single Go binary on any cloud or self-hosted environment. It works with any… | 15 | 2289 | active |
| Apache RocketMQ Apache RocketMQ Spring Integration is a Spring Boot starter that lets Java developers quickly integrate RocketMQ messaging into Spring appl… | 78 | 2273 | active |
| teamgram/teamgram-server Teamgram Server is an unofficial open-source MTProto 2.0 server implementation written in Go that is compatible with official Telegram clie… | 62 | 2271 | active |
| karafka/karafka Karafka is a multi-threaded Ruby and Rails framework for efficiently consuming and producing Apache Kafka messages, built on librdkafka. It… | 97 | 2252 | stable |
| Storm Apache Storm (originally nathanmarz/storm) is a distributed, fault-tolerant realtime computation system for stream processing, continuous c… | 32 | 8760 | maintenance |
| sohutv/mqcloud MQCloud is an enterprise-grade one-stop management platform for Apache RocketMQ, combining client SDK, operations, monitoring, and alerting… | 74 | 2230 | active |
| Enqueue Enqueue is a production-ready messaging solution for PHP that provides a unified API for creating, sending, and reading messages across man… | 86 | 2220 | stable |
| paolosalvatori/ServiceBusExplorer Service Bus Explorer is a Windows desktop application for administering Azure Service Bus messaging entities such as queues, topics, subscr… | 92 | 2217 | active |
| Apache Fluss Apache Fluss is a lakehouse-native streaming storage built for real-time analytics and AI, serving as the real-time data layer for Lakehous… | 80 | 2216 | active |
| MCP Agent Mail MCP Agent Mail is an asynchronous coordination layer for AI coding agents, exposed as an HTTP-only FastMCP server. It gives agents persiste… | 75 | 2214 | active |
| Fireworq Fireworq is a lightweight, high-performance, language-independent job queue system written in Go, backed by MySQL for reliability. It expos… | 67 | 2210 | stable |
| Blizzard/node-rdkafka node-rdkafka is a high-performance Node.js client for Apache Kafka that wraps the native librdkafka C/C++ library. It handles partition bal… | 94 | 2208 | active |
| louislva/claude-peers-mcp An MCP server that lets multiple Claude Code sessions on the same machine discover each other and exchange instant messages via a local bro… | 47 | 2208 | active |
| sequinstream/sequin Sequin is an open-source change data capture (CDC) platform for Postgres, deployed as a standalone Docker container that streams database c… | 57 | 2206 | active |
| Ice Ice (Internet Communications Engine) is a complete RPC framework for building networked applications, using the Slice IDL to generate clien… | 92 | 2193 | stable |
| thingsboard/thingsboard-gateway An open-source Python IoT gateway that integrates legacy and third-party devices with the ThingsBoard IoT platform. It acts as a protocol a… | 96 | 2192 | active |
| php-rdkafka/php-rdkafka php-rdkafka is a stable, production-ready PHP extension binding to librdkafka for Apache Kafka. It provides low-level and high-level produc… | 76 | 2180 | stable |
| bytebeamio/rumqtt rumqtt is a Rust ecosystem implementing the MQTT standard, consisting of rumqttc (a high-level async MQTT client) and rumqttd (a high-perfo… | 66 | 2174 | active |
| Particular/NServiceBus NServiceBus is a .NET messaging framework for building distributed systems and async microservices, providing abstractions over message que… | 96 | 2171 | stable |
| warpstreamlabs/bento Bento is a high-performance, resilient stream processor written in Go that connects a wide range of sources and sinks (Kafka, Pub/Sub, Redi… | 89 | 2155 | active |
| streamdal/plumber plumber is a single-binary CLI tool for inspecting, reading, writing, and piping data across messaging systems like Kafka, RabbitMQ, and GC… | 41 | 2155 | active |
| ideawu/ssdb SSDB is a fast, Redis-compatible NoSQL key-value database written in C++ that stores data on disk using LevelDB/RocksDB-style storage. It s… | 23 | 8307 | maintenance |
| vyuldashev/laravel-queue-rabbitmq A RabbitMQ queue driver for the Laravel framework, implemented as a Composer-installable PHP package. It lets Laravel applications use Rabb… | 70 | 2132 | active |
| ruby-shoryuken/shoryuken Shoryuken is a super-efficient, thread-based message processor for Amazon SQS written in Ruby. It integrates with Rails Active Job and prov… | 93 | 2125 | active |
| Foundatio Foundatio is a C# library of pluggable abstractions for building loosely coupled distributed applications, covering caching, queues, messag… | 93 | 2102 | active |
| antirez/disque Disque is an in-memory, distributed message broker and job queue written in C, designed to capture the 'Redis as a jobs queue' use case in … | 23 | 8076 | maintenance |
| crossbario/crossbar Crossbar.io is an open-source application router implementing the WAMP protocol over WebSocket, plus REST/HTTP and MQTT bridging, for build… | 95 | 2062 | active |
| clojure/core.async core.async is a Clojure/ClojureScript library providing facilities for asynchronous programming and communication, centered on channels and… | 68 | 2054 | stable |
| Commanded Commanded is an Elixir framework for building applications using the CQRS (Command Query Responsibility Segregation) and Event Sourcing (ES… | 85 | 2035 | stable |
| apache/bookkeeper Apache BookKeeper is a scalable, fault-tolerant, low-latency distributed storage service optimized for append-only workloads, offering repl… | 93 | 2014 | stable |
| fede1024/rust-rdkafka rust-rdkafka is a fully asynchronous, futures-based Apache Kafka client library for Rust built on top of the librdkafka C library. It provi… | 70 | 2009 | stable |
| Cysharp/MessagePipe MessagePipe is a high-performance in-memory and distributed messaging pipeline library for .NET and Unity. It supports pub/sub, mediator pa… | 81 | 2001 | active |
| pubkey/broadcast-channel A JavaScript library implementing the BroadcastChannel API across browsers, WebWorkers, Node.js, and Deno, enabling message passing between… | 79 | 2001 | active |
| Pravega Pravega is an open-source distributed storage service that implements Streams as a first-class primitive: durable, elastic, append-only, un… | 23 | 2000 | active |
| GoBelieveIO/im_service A Go-based instant messaging server supporting peer-to-peer, group, and chatroom messages with cluster deployment. It scales to 500k concur… | 76 | 1986 | active |
| asaskevich/EventBus A lightweight event bus library for Go supporting synchronous and asynchronous subscribe/publish patterns with topic-based handlers. It als… | 32 | 1983 | stable |
| Aedes MQTT Broker Aedes is a barebone, stream-based MQTT broker for Node.js that can run on any stream server, supporting MQTT 3.1/3.1.1 over TCP, TLS, and W… | 96 | 1969 | active |
| Terry-Mao/goim goim is a high-performance instant messaging (IM) push server written in pure Go, supporting WebSocket, TCP, and HTTP long-polling protocol… | 23 | 7375 | maintenance |
| mochi-mqtt/server Mochi-MQTT is a fully compliant, embeddable MQTT v5 (and v3.1.1) broker written in Go, usable as a standalone binary or as a library inside… | 76 | 1930 | active |
| pheanstalk/pheanstalk Pheanstalk is a fully typed PHP 8.1+ client library for the beanstalkd work queue server. It provides producer and consumer APIs for puttin… | 65 | 1919 | active |
| openremote/openremote OpenRemote is a 100% open-source (AGPLv3) IoT platform for device management, automation, and data visualization, built on a Java backend w… | 93 | 1909 | active |
| bbc/sqs-consumer A Node.js/TypeScript library that wraps Amazon SQS into a simple consumer API, letting developers define an async message handler without b… | 98 | 1908 | active |
| XMall XMall is a distributed e-commerce shopping mall application built on a SOA architecture with separated frontend and backend. The storefront… | 32 | 7218 | maintenance |
| Baetyl Baetyl is an open-source edge computing framework from Linux Foundation Edge that extends cloud computing, data, and services to edge devic… | 23 | 1900 | active |
| Proto.Actor Proto.Actor is an ultra-fast, cross-platform actor framework for Go, C#/.NET, and Java/Kotlin for building distributed, message-driven syst… | 53 | 1896 | active |
| faust-streaming/faust Faust-streaming is a Python stream processing library that ports Kafka Streams ideas to Python using asyncio, letting developers build dist… | 96 | 1889 | active |
| nisshi-io/nisshi Nisshi is a stateless, Kafka API-compatible message broker written in async Rust with pluggable storage engines (PostgreSQL, SQLite/libSQL,… | 90 | 1888 | active |
| discord/manifold Manifold is an Elixir/Erlang library that optimizes batch message passing between Erlang nodes by grouping PIDs by remote node and distribu… | 60 | 1851 | stable |
| RobustMQ RobustMQ is a next-generation message queue infrastructure written in Rust that supports multiple protocols (MQTT, Kafka, AMQP) with a sing… | 92 | 1843 | active |
| NikolayS/PgQue PgQue is a zero-bloat job/event queue for PostgreSQL implemented in pure SQL and PL/pgSQL, rebuilt from Skype's battle-tested PgQ architect… | 60 | 1831 | active |
| alibaba/MongoShake MongoShake is a Go-based universal data replication platform built on MongoDB's oplog, fetching changes from a source MongoDB and replaying… | 92 | 1820 | active |
| smrchy/rsmq RSMQ is a lightweight message queue library for Node.js built entirely on Redis, requiring no dedicated queue server. It supports FIFO deli… | 62 | 1820 | stable |
| beanstalkd/beanstalkd Beanstalkd is a simple, fast, general-purpose work queue server written in C with a text-based network protocol. It is designed to run time… | 34 | 6705 | maintenance |
| apache/storm Apache Storm is a free and open-source distributed realtime computation system for processing unbounded streams of data, providing primitiv… | 97 | 6696 | maintenance |