function: message-queue
582 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| krisleech/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 |
| bloomberg/blazingmq BlazingMQ is a distributed, high-performance message queuing system written in C++, providing durable, fault-tolerant queues with rich rout… | 73 | 3208 | 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… | 96 | 3180 | active |
| celery/kombu Kombu is a Python messaging library providing an idiomatic high-level interface to the AMQP protocol and pluggable transports for RabbitMQ,… | 87 | 3136 | stable |
| eclipse-zenoh/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… | 99 | 3126 | active |
| slact/nchan Nchan is a scalable pub/sub message server and proxy implemented as an Nginx module, supporting Websocket, EventSource (SSE), long-polling,… | 71 | 3065 | 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.… | 90 | 3059 | active |
| 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… | 76 | 3032 | 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… | 96 | 2993 | stable |
| LockGit/gochat gochat is a lightweight instant messaging (IM) server written in pure Go, supporting private messages and room broadcast messages with WebS… | 75 | 2929 | active |
| 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… | 88 | 2918 | active |
| frain-dev/convoy Convoy is an open-source, high-performance webhooks gateway for reliably ingesting, persisting, debugging, and delivering webhook events at… | 95 | 2862 | 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… | 39 | 2846 | 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… | 73 | 2836 | active |
| liftbridge-io/liftbridge Liftbridge is a lightweight, fault-tolerant message streaming system written in Go that implements a durable, replicated message log on top… | 74 | 2799 | active |
| golevelup/nestjs A monorepo of NestJS modules and utilities from golevelup, including RabbitMQ integration (RPC and pub/sub), Hasura event handlers, Stripe … | 90 | 2739 | 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 … | 76 | 2703 | active |
| argoproj/argo-events Argo Events is an event-driven workflow automation framework for Kubernetes that triggers actions like creating Kubernetes objects, invokin… | 93 | 2687 | active |
| elixir-broadway/broadway Broadway is an Elixir library for building concurrent, multi-stage data ingestion and processing pipelines on top of GenStage. It provides … | 75 | 2677 | stable |
| rebus-org/Rebus Rebus is a lean, free service bus implementation for .NET that provides asynchronous messaging between services following the 'smart endpoi… | 76 | 2657 | 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… | 58 | 2630 | 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… | 99 | 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… | 67 | 10251 | 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… | 80 | 2564 | 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… | 90 | 2538 | active |
| liangdas/mqant mqant is a concise, high-performance distributed microservice framework written in Go, originally designed for real-time game servers. It p… | 32 | 2517 | 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… | 99 | 2495 | 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 … | 98 | 2488 | active |
| eclipse-iceoryx/iceoryx2 iceoryx2 is an ultra-low latency inter-process communication middleware with a Rust core, offering true zero-copy, lock-free messaging via … | 80 | 2468 | active |
| 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… | 86 | 2453 | active |
| apache/activemq Apache ActiveMQ is a high-performance, multi-protocol, Java-based open source message broker supporting JMS/Jakarta Messaging, AMQP, MQTT, … | 98 | 2451 | stable |
| 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… | 73 | 2438 | 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 | 2421 | active |
| dashersw/cote cote is a Node.js library for building zero-configuration microservices with automatic service discovery. It provides Responder/Requester, … | 61 | 2385 | stable |
| 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… | 82 | 2384 | 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… | 75 | 2378 | active |
| anycable/anycable AnyCable is an open-source realtime server written in Go that provides reliable two-way communication over WebSockets and SSE with built-in… | 98 | 2373 | 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… | 92 | 2371 | stable |
| anthdm/hollywood Hollywood is a fast, lightweight actor model engine for Go, supporting local and clustered distributed actors with guaranteed message deliv… | 71 | 2325 | active |
| JasperFx/wolverine Wolverine is a next-generation .NET mediator and message bus framework for building robust event-driven server-side applications. It provid… | 95 | 2322 | 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… | 50 | 2322 | active |
| taskiq-python/taskiq Taskiq is an asynchronous distributed task queue for Python, inspired by Celery and Dramatiq. It lets you define tasks as decorated functio… | 99 | 2304 | 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… | 18 | 2286 | active |
| apache/rocketmq-spring Apache RocketMQ Spring Integration is a Spring Boot starter that lets Java developers quickly integrate RocketMQ messaging into Spring appl… | 84 | 2270 | active |
| karafka/karafka Karafka is a multi-threaded Ruby and Rails framework for efficiently consuming and producing Apache Kafka messages, built on librdkafka. It… | 99 | 2256 | stable |
| 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… | 66 | 2255 | active |
| nathanmarz/storm Apache Storm (originally nathanmarz/storm) is a distributed, fault-tolerant realtime computation system for stream processing, continuous c… | 32 | 8765 | maintenance |
| sohutv/mqcloud MQCloud is an enterprise-grade one-stop management platform for Apache RocketMQ, combining client SDK, operations, monitoring, and alerting… | 80 | 2228 | active |
| Pusher Channels The official Pusher Channels JavaScript client library for subscribing to channels and receiving realtime events over WebSockets with HTTP … | 97 | 2220 | active |
| php-enqueue/enqueue-dev Enqueue is a production-ready messaging solution for PHP that provides a unified API for creating, sending, and reading messages across man… | 73 | 2219 | stable |
| paolosalvatori/ServiceBusExplorer Service Bus Explorer is a Windows desktop application for administering Azure Service Bus messaging entities such as queues, topics, subscr… | 85 | 2213 | active |
| 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… | 61 | 2211 | active |
| fireworq/fireworq Fireworq is a lightweight, high-performance, language-independent job queue system written in Go, backed by MySQL for reliability. It expos… | 67 | 2207 | stable |
| 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… | 50 | 2201 | active |
| zeroc-ice/ice Ice (Internet Communications Engine) is a complete RPC framework for building networked applications, using the Slice IDL to generate clien… | 91 | 2191 | stable |
| sequinstream/sequin Sequin is an open-source change data capture (CDC) platform for Postgres, deployed as a standalone Docker container that streams database c… | 63 | 2191 | 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… | 74 | 2181 | 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… | 98 | 2177 | active |
| Particular/NServiceBus NServiceBus is a .NET messaging framework for building distributed systems and async microservices, providing abstractions over message que… | 98 | 2168 | 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… | 72 | 2160 | 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… | 44 | 2157 | 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 | 8320 | 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… | 75 | 2126 | 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 |
| Dicklesworthstone/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… | 77 | 2114 | 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… | 78 | 2113 | active |
| 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… | 91 | 2112 | active |
| FoundatioFx/Foundatio Foundatio is a C# library of pluggable abstractions for building loosely coupled distributed applications, covering caching, queues, messag… | 96 | 2098 | 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 | 8074 | 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 | 2064 | active |
| clojure/core.async core.async is a Clojure/ClojureScript library providing facilities for asynchronous programming and communication, centered on channels and… | 71 | 2051 | stable |
| commanded/commanded Commanded is an Elixir framework for building applications using the CQRS (Command Query Responsibility Segregation) and Event Sourcing (ES… | 91 | 2030 | stable |
| apache/bookkeeper Apache BookKeeper is a scalable, fault-tolerant, low-latency distributed storage service optimized for append-only workloads, offering repl… | 89 | 2009 | stable |
| pubkey/broadcast-channel A JavaScript library implementing the BroadcastChannel API across browsers, WebWorkers, Node.js, and Deno, enabling message passing between… | 83 | 1997 | active |
| pravega/pravega Pravega is an open-source distributed storage service that implements Streams as a first-class primitive: durable, elastic, append-only, un… | 27 | 1997 | active |
| 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… | 74 | 1996 | stable |
| asaskevich/EventBus A lightweight event bus library for Go supporting synchronous and asynchronous subscribe/publish patterns with topic-based handlers. It als… | 32 | 1984 | stable |
| 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… | 77 | 1983 | active |
| Cysharp/MessagePipe MessagePipe is a high-performance in-memory and distributed messaging pipeline library for .NET and Unity. It supports pub/sub, mediator pa… | 83 | 1973 | active |
| moscajs/aedes 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 | 1967 | 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 | 7372 | maintenance |
| 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… | 71 | 1922 | active |
| 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… | 79 | 1919 | 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… | 97 | 1907 | active |
| XMall XMall is a distributed e-commerce shopping mall application built on a SOA architecture with separated frontend and backend. The storefront… | 32 | 7220 | maintenance |
| baetyl/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 |
| faust-streaming/faust Faust-streaming is a Python stream processing library that ports Kafka Streams ideas to Python using asyncio, letting developers build dist… | 99 | 1884 | 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… | 94 | 1880 | active |
| nisshi-io/nisshi Nisshi is a stateless, Kafka API-compatible message broker written in async Rust with pluggable storage engines (PostgreSQL, SQLite/libSQL,… | 88 | 1851 | 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… | 64 | 1848 | stable |
| alibaba/MongoShake MongoShake is a Go-based universal data replication platform built on MongoDB's oplog, fetching changes from a source MongoDB and replaying… | 82 | 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… | 66 | 1816 | stable |
| 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… | 65 | 1804 | active |
| 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… | 38 | 6700 | maintenance |
| robustmq/robustmq RobustMQ is a next-generation message queue infrastructure written in Rust that supports multiple protocols (MQTT, Kafka, AMQP) with a sing… | 93 | 1787 | active |
| apache/storm Apache Storm is a free and open-source distributed realtime computation system for processing unbounded streams of data, providing primitiv… | 97 | 6698 | maintenance |
| fereidani/kanal Kanal is a high-performance Rust channel library implementing CSP-style message passing with both synchronous and asynchronous APIs. It sup… | 74 | 1759 | active |
| esl/MongooseIM MongooseIM is a robust, scalable XMPP messaging server built in Erlang, designed for large enterprise instant messaging installations. It i… | 95 | 1750 | active |
| emqx/CocoaMQTT CocoaMQTT is an MQTT v3.1.1 and v5.0 client library for iOS, macOS, tvOS, and visionOS written in Swift 5. It supports TCP and WebSocket tr… | 96 | 1748 | active |
| apache/eventmesh Apache EventMesh is a cloud-native, serverless event middleware for building distributed event-driven applications. It provides a unified C… | 75 | 1746 | active |