function: message-queue
582 products, primary matches first, then adoption-weighted; health v2 shown.
| Product | Health v2 | Stars | Maturity |
|---|---|---|---|
| nanomsg/nanomsg nanomsg is a C library implementing lightweight 'scalability protocols' for common messaging patterns such as request/reply, publish/subscr… | 88 | 6291 | maintenance |
| discourse/message_bus MessageBus is a Ruby gem providing a reliable publish/subscribe messaging bus for server-to-server and server-to-web-client communication. … | 75 | 1662 | stable |
| message-db/message-db Message DB is a fully-featured event store and message store implemented in PostgreSQL, supporting Pub/Sub, event sourcing, streams, catego… | 23 | 1652 | active |
| hashicorp/serf Serf is a decentralized service discovery and orchestration tool from HashiCorp that uses an efficient gossip protocol to manage cluster me… | 84 | 6069 | maintenance |
| apache/pekko Apache Pekko is an open-source JVM framework for building concurrent, distributed, and resilient message-driven applications using the Acto… | 77 | 1629 | active |
| spring-projects/spring-integration Spring Integration extends the Spring programming model to implement Enterprise Integration Patterns, enabling lightweight messaging within… | 99 | 1626 | stable |
| wellle/rmq rmq is a message queue library for Go backed by Redis, supporting connections, queues, consumers, batching, and Redis clusters. It lets Go … | 23 | 1617 | active |
| bobohume/gonet gonet is a Go-based distributed game server framework built around an actor model with virtual actors, in-memory MMO state, and a stub-base… | 54 | 1610 | active |
| elixir-lang/gen_stage GenStage is an Elixir specification and behaviour for exchanging events between producer and consumer stages with built-in back-pressure. I… | 75 | 1590 | stable |
| 2881099/FreeIM FreeIM is a simple, high-performance WebSocket-based instant messaging component for .NET/.NETCore, supporting clustered deployment via Red… | 48 | 1583 | active |
| RailsEventStore/rails_event_store Rails Event Store (RES) is a Ruby library for publishing, consuming, storing, and retrieving domain events, built on Active Record. It serv… | 99 | 1551 | stable |
| nats-io/nats.rs async-nats is a Rust client library for the NATS cloud-native messaging system, built on Tokio. It supports Core NATS, JetStream, Key-Value… | 90 | 1536 | active |
| edgexfoundry/edgex-go EdgeX Foundry is a vendor-neutral open source framework for IoT edge computing, and this repository contains the Go implementation of its c… | 83 | 1536 | active |
| akira/exq Exq is a job processing library for Elixir that uses Redis as its backing store and is compatible with Resque and Sidekiq job formats. It h… | 92 | 1531 | stable |
| janbjorge/pgqueuer PgQueuer is a Python library that turns an existing PostgreSQL database into a background job and task queue using FOR UPDATE SKIP LOCKED a… | 86 | 1519 | active |
| broadway/broadway Broadway is a PHP library providing infrastructure and testing helpers for building CQRS and event-sourced applications. It offers loosely … | 10 | 1509 | active |
| mxsm/rocketmq-rust An unofficial, high-performance Rust implementation of Apache RocketMQ, providing message broker, NameServer, producer, and consumer compon… | 81 | 1505 | active |
| apache/inlong Apache InLong is a one-stop, full-scenario integration framework for massive data, supporting data ingestion, synchronization, and subscrip… | 90 | 1497 | stable |
| smarty/go-disruptor A Go port of the LMAX Disruptor, a high-performance inter-thread/goroutine messaging library built on a pre-allocated ring buffer. It achie… | 69 | 1492 | active |
| ThingsGateway/ThingsGateway ThingsGateway is an open-source, cross-platform industrial IoT edge gateway built on .NET 8 for high-performance data acquisition, edge pro… | 75 | 1476 | active |
| mosquito/aio-pika aio-pika is an asynchronous Python client library for RabbitMQ built on top of aiormq, providing an object-oriented asyncio API for AMQP 0.… | 93 | 1472 | stable |
| ESPresense/ESPresense ESPresense is ESP32 firmware that scans for BLE devices and reports indoor presence/positioning data over MQTT for use with Home Assistant … | 90 | 1471 | active |
| Netflix/mantis Mantis is a Netflix open-source stream processing platform written in Java for building realtime, cost-effective, operations-focused applic… | 67 | 1470 | active |
| closeio/tasktiger TaskTiger is a Python task queue library backed by Redis, supporting per-task subprocess forking, unique queues, task locking, and flexible… | 67 | 1467 | active |
| fujibee/agmsg agmsg is a bash + SQLite CLI tool that lets CLI AI coding agents (Claude Code, Codex, Gemini CLI, Copilot CLI, and others) message each oth… | 81 | 1459 | active |
| oldmoe/litestack Litestack is a Ruby gem that bundles SQLite-based data infrastructure for Ruby and Rails applications, providing a database, cache, job que… | 31 | 1453 | active |
| kafka-rust/kafka-rust A Rust client library for Apache Kafka providing producer and consumer APIs with offset management and TLS support via rustls. It is a crat… | 63 | 1448 | active |
| wez/govee2mqtt A Rust-based bridge that connects Govee smart lights and devices to Home Assistant via the MQTT integration. It uses LAN control, Govee's u… | 65 | 1432 | active |
| ruby-amqp/bunny Bunny is a mature, feature-complete Ruby client library for RabbitMQ implementing the AMQP 0-9-1 protocol. It lets Ruby applications publis… | 83 | 1425 | stable |
| apache/rocketmq-client-go The official Apache RocketMQ client SDK written in pure Go, supporting publishing and consuming messages against RocketMQ brokers. It cover… | 60 | 1412 | active |
| aio-libs/aiokafka aiokafka is an asyncio-based Python client library for Apache Kafka, providing AIOKafkaProducer and AIOKafkaConsumer high-level classes. It… | 80 | 1399 | active |
| emqx/neuron Neuron is an open-source industrial IoT connectivity server written in C that bridges factory-floor devices (PLCs, sensors, meters) with mo… | 95 | 1390 | active |
| procrastinate-org/procrastinate Procrastinate is a Python distributed task processing library that uses PostgreSQL as its task queue backend, supporting both sync and asyn… | 96 | 1374 | active |
| IoTSharp/IoTSharp IoTSharp is an open-source industrial IoT platform built on .NET for device access, telemetry collection, rule-chain processing, visualizat… | 84 | 1372 | active |
| apalis-dev/apalis Apalis is a type-safe, extensible background processing library for Rust for building durable, distributed job and task processing systems.… | 82 | 1363 | active |
| synrc/n2o N2O is an embeddable message protocol loop library for WebSocket, HTTP, MQTT, and TCP servers written in Erlang. It provides process manage… | 61 | 1341 | active |
| vmihailenco/taskq A Go library for asynchronous task/job queues with pluggable backends including Redis, AWS SQS, IronMQ, and in-memory. It turns Go function… | 31 | 1341 | active |
| disruptor-net/Disruptor-net A .NET port of the LMAX Disruptor, a high-performance inter-thread message passing framework built around a pre-allocated ring buffer with … | 57 | 1330 | active |
| eclipse-cyclonedds/cyclonedds Eclipse Cyclone DDS is a performant, robust open-source C implementation of the OMG DDS (Data Distribution Service) publish-subscribe middl… | 91 | 1327 | stable |
| eclipse-paho/paho.mqtt.cpp The Eclipse Paho MQTT C++ client library lets modern C++ (C++17+) applications connect to MQTT brokers to publish messages, subscribe to to… | 79 | 1324 | stable |
| Bronya0/Kafka-King Kafka-King is a modern cross-platform desktop GUI client for Apache Kafka, built with Wails and franz-go. It lets developers and administra… | 87 | 1300 | active |
| puniverse/quasar Quasar is a JVM library providing lightweight threads (fibers), Go-like channels, and Erlang-like actors for Java and Kotlin, using bytecod… | 23 | 4551 | maintenance |
| rigtorp/SPSCQueue A header-only C++11 library providing a bounded single-producer single-consumer wait-free and lock-free queue. It is optimized for high-per… | 23 | 1280 | stable |
| vercel/bidc BIDC is a TypeScript library providing bidirectional channels for asynchronous communication between JavaScript execution contexts such as … | 44 | 1277 | active |
| Alpakka Akka is a JVM-based platform built on the actor model for building concurrent, distributed, and resilient applications, comprising core lib… | 94 | 1268 | active |
| encode/broadcaster A Python library providing a simple async broadcast/publish-subscribe API over multiple backends including Redis PUB/SUB, Redis Streams, Ka… | 10 | 1268 | active |
| ptrofimov/beanstalk_console A web-based admin console for the Beanstalkd work queue server, written in PHP. It provides realtime tube statistics, job inspection and ma… | 94 | 1267 | active |
| Expensify/Bedrock Bedrock is a distributed database server built by Expensify on top of SQLite, providing WAN replication, active/active automatic failover, … | 96 | 1264 | active |
| zerodha/dungbeetle DungBeetle is a lightweight, single-binary distributed job server for queuing and asynchronously executing heavy SQL read jobs (such as rep… | 60 | 1264 | active |
| pebbe/zmq4 A Go binding (wrapper via cgo) for the native ZeroMQ version 4 messaging library. It exposes ZeroMQ sockets and patterns such as pubsub, pi… | 48 | 1261 | stable |
| faye/faye Faye is a publish-subscribe messaging library based on the Bayeux protocol, providing message servers for Node.js and Rack (Ruby) applicati… | 44 | 4385 | maintenance |
| drasi-project/drasi-platform Drasi is a Data Change Processing platform that monitors data sources for changes, evaluates them against continuously running Cypher queri… | 75 | 1245 | active |
| nats-io/nats.py nats.py is the official asyncio-based Python client for the NATS messaging system, supporting pub/sub, request/reply, and JetStream. It als… | 95 | 1243 | active |
| thangchung/go-coffeeshop A practical event-driven microservices demo application for a coffee shop, written in Go with services for products, counter, barista, and … | 23 | 4360 | maintenance |
| durable-workflow/workflow Durable Workflow (formerly Laravel Workflow) is a Laravel-native durable workflow engine for defining and running long-running, fault-toler… | 100 | 1237 | active |
| amqp-rs/lapin Lapin is an async AMQP 0-9-1 client library for Rust, primarily targeting RabbitMQ. It provides a futures-based API and is runtime-agnostic… | 75 | 1233 | stable |
| php-amqplib/RabbitMqBundle A Symfony bundle that integrates RabbitMQ messaging into PHP applications via the php-amqplib library. It provides producers, consumers, an… | 70 | 1231 | active |
| taoweiji/MixPush MixPush is an Android SDK that unifies integration with six vendor push platforms (Xiaomi, Huawei, Meizu, OPPO, VIVO, and Apple APNs) behin… | 48 | 1227 | active |
| corosync/corosync Corosync is a C-based Group Communication System providing a closed process group communication model with virtual synchrony guarantees, pl… | 73 | 1218 | active |
| hivemq/hivemq-community-edition HiveMQ Community Edition is a Java-based open-source MQTT broker fully supporting MQTT 3.x and MQTT 5, serving as the foundation of the Hiv… | 91 | 1207 | active |
| lcm-proj/lcm LCM (Lightweight Communications and Marshalling) is a set of libraries and tools for low-latency, high-bandwidth publish/subscribe message … | 72 | 1203 | stable |
| jookies/jasmin Jasmin is an open-source SMS gateway written in Python on top of the Twisted event-driven networking engine. It supports SMPP client/server… | 58 | 1199 | active |
| lemunozm/message-io message-io is a Rust library that provides a fast, event-driven networking API over TCP, UDP, and WebSocket transports. It manages OS socke… | 72 | 1197 | active |
| nextgenhealthcare/connect Mirth Connect by NextGen Healthcare is an open-source healthcare integration engine that filters, transforms, extracts, and routes messages… | 23 | 1190 | active |
| taoensso/carmine Carmine is a mature, high-performance Redis client for Clojure with an idiomatic API, connection pooling, and automatic de/serialization of… | 72 | 1178 | active |
| wind-c/comqtt Comqtt is a lightweight, high-performance MQTT broker written in Go supporting MQTT v3.0, v3.1.1, and v5.0. It can run as a standalone serv… | 93 | 1175 | active |
| jcubic/sysend Sysend.js is a small dependency-free JavaScript library that enables message passing and synchronization between web pages open in the same… | 56 | 1163 | active |
| EdwinVW/pitstop Pitstop is a sample Garage Management System application demonstrating software-architecture concepts such as microservices, CQRS, event so… | 75 | 1162 | active |
| commanded/eventstore An event store library for Elixir that uses PostgreSQL as its underlying persistence engine. It supports appending and reading event stream… | 66 | 1162 | active |
| IceFireDB/IceFireDB IceFireDB is a decentralized, high-performance distributed database written in Go that bridges Web2 and Web3 ecosystems. It offers Redis-co… | 67 | 1154 | active |
| quickfix-j/quickfixj QuickFIX/J is a full-featured, 100% Java messaging engine for the FIX protocol, supporting FIX 4.0 through FIXLatest and FIXT 1.1. It provi… | 94 | 1150 | stable |
| aws-samples/aws-serverless-ecommerce-platform A sample serverless backend implementation for an e-commerce website built on AWS services like Lambda, EventBridge, AppSync, and API Gatew… | 10 | 1146 | active |
| senecajs/seneca Seneca is a microservices toolkit for Node.js that lets you organize business logic as message-based commands selected by JSON pattern matc… | 67 | 3959 | maintenance |
| whatyouhide/redix Redix is a fast, pipelined, resilient Redis (and Valkey) client written in pure Elixir. It provides an idiomatic interface for sending arbi… | 77 | 1140 | stable |
| griddynamics-archive/MMWormhole MMWormhole is an Objective-C library that enables message passing between an iOS or OS X app and its extensions via files written to a shar… | 23 | 3932 | maintenance |
| certtools/intelmq IntelMQ is an open-source solution for IT security teams (CERTs, CSIRTs, SOCs) for collecting and processing security feeds using a message… | 63 | 1133 | active |
| ro31337/libretaxi LibreTaxi is an open-source ridesharing proof-of-concept that connects passengers and drivers through a Telegram bot instead of a dedicated… | 23 | 3916 | maintenance |
| servo/ipc-channel ipc-channel is a Rust library providing an inter-process communication implementation of Rust channels, designed as a drop-in replacement f… | 80 | 1124 | stable |
| awspring/spring-cloud-aws Spring Cloud AWS is a community-maintained Spring and Spring Boot integration project for AWS managed services such as S3, SQS, SNS, Dynamo… | 95 | 1120 | active |
| gautema/CQRSlite CQRSlite is a lightweight CQRS and Event Sourcing framework for .NET that provides building blocks like command dispatching, event publishi… | 56 | 1119 | active |
| davidyaha/graphql-redis-subscriptions A TypeScript library implementing the PubSubEngine and AsyncIterator interfaces from graphql-subscriptions on top of Redis Pub/Sub. It lets… | 33 | 1118 | active |
| symfony/messenger Symfony Messenger is a PHP component that helps applications send and receive messages to other applications or via message queues. It prov… | 96 | 1110 | stable |
| aws/pgactive pgactive is a PostgreSQL extension written in C that enables active-active replication, allowing multiple database instances in a cluster t… | 86 | 1108 | active |
| childe/gohangout Gohangout is a Logstash-like data processing tool written in Go that consumes events (commonly from Kafka), applies configurable filters, a… | 74 | 1103 | active |
| chaps-io/gush Gush is a Ruby gem for defining and running parallel workflows as directed acyclic graphs, using Redis for storage and ActiveJob for job sc… | 53 | 1100 | active |
| nytimes/gizmo Gizmo is a Go microservice toolkit from The New York Times providing packages for building HTTP/JSON servers and pubsub daemons with standa… | 55 | 3772 | maintenance |
| mpusher/mpush MPush is an open-source real-time message push system written in Java on Netty, with a modular server, SDKs for Android, iOS, Java, and Jav… | 23 | 3770 | maintenance |
| 256dpi/arduino-mqtt An Arduino library wrapping the lwmqtt MQTT 3.1.1 client with an Arduino-style API. It supports many Arduino-compatible boards and shields … | 71 | 1092 | stable |
| edgurgel/poxa Poxa is an open-source Elixir server implementing the Pusher protocol, compatible with existing Pusher client libraries. It supports public… | 23 | 1086 | active |
| iioter/iotgateway IoTGateway is a cross-platform, B/S-architecture industrial IoT gateway built on .NET that connects southbound to industrial devices (PLCs,… | 74 | 1082 | active |
| belaban/JGroups JGroups is a Java toolkit for reliable group communication and messaging between cluster nodes. It provides configurable protocol stacks co… | 77 | 1074 | stable |
| linkedin/databus Databus is LinkedIn's source-agnostic distributed change data capture (CDC) system that reliably captures and streams primary data store ch… | 32 | 3679 | maintenance |
| spring-cloud/spring-cloud-stream Spring Cloud Stream is a Java framework for building event-driven microservices connected via messaging systems like Kafka and RabbitMQ. It… | 95 | 1070 | active |
| mqttsnet/thinglinks ThingLinks is an enterprise-grade, multi-tenant SaaS IoT platform built on Spring Cloud microservices with a Netty/BifroMQ-based engine sup… | 88 | 1070 | active |
| jeffbass/imagezmq imageZMQ is a set of Python classes that transport OpenCV images between computers using PyZMQ messaging. It enables distributed computer v… | 62 | 1069 | stable |
| lensesio/stream-reactor Stream Reactor is a collection of Apache 2.0 licensed Kafka Connect sinks and sources maintained by Lenses.io since 2016. It provides conne… | 95 | 1068 | active |
| deviceinsight/kafkactl kafkactl is a Go-based command-line interface for managing Apache Kafka clusters, supporting operations on topics, consumer groups, ACLs, b… | 96 | 1067 | active |
| yiisoft/yii2-queue A Yii2 framework extension for running tasks asynchronously via queues, with drivers for DB, Redis, RabbitMQ/AMQP, Beanstalk, ActiveMQ, and… | 68 | 1064 | active |
| apache/celeborn Apache Celeborn is an elastic, high-performance intermediate data service for big data compute engines, focused on managing shuffle and spi… | 95 | 1061 | active |
| java-up-up/damai A high-concurrency online ticket booking system (modeled after Damai/大麦网) built with SpringCloud, SpringCloud Alibaba, Kafka, Redis, Sentin… | 67 | 1061 | active |