Message-queue Packages

A lightweight event-driven microservices package for RabbitMQ in Node.js. Enables scalable message publishing and consuming for distributed systems.

Rivulex is a high-performance messaging library leveraging Redis Streams for reliable event-driven communication within distributed systems.

Robust WebSocket utilities for Nostr applications with automatic reconnection, supporting both ESM and CommonJS. Features channel-based messaging, heartbeat monitoring, message queueing, and comprehensive error handling with type-safe handlers.

Postgres Message Queue (PSMQ) JavaScript Client Library

RedisSMQ Common Library provides many components that are mainly used by RedisSMQ and RedisSMQ Monitor.

A Web UI for the RedisSMQ Monitor application

Rivulex is a high-performance messaging library leveraging Redis Streams for reliable event-driven communication within distributed systems.

Universal NodeJS wrapper for working with RabbitMQ, Redis pub/sub, Kafka and other message queues

A simple message queue using socket.io (typescript support)

Helpers for graphile-worker that add job dependencies (hierarchical workflows) and support saving intermediary results for improved job recovery and progress management.

👉 https://hyper.fun/c/carbon-icon-message-queue/1.3.0

Node web server (koajs), extending routes to a message queue (amqp 0-9-1) of 'topic' and 'action'.

NodeJS Service for message queue (amqp 0-9-1) of 'topic' and 'action' responding

StreamQ is a library for processing events and managing message queues.

Node.js client SDK for RocketMQ with gRPC proxy support

High-performance Node.js client SDK for RocketMQ with Native Addon support (Node.js 16+)

A RabbitMQ-based event management library for Node.js, providing message publishing, subscription, and rerouting of unroutable messages with support for persistence and idempotency.

A promise-based, broker-agnostic client for sending and receiving messages via RabbitMQ

Postgres Message Queue (PGMQ) JavaScript Client Library for Midway.js, supports transaction and exchange via Route