A message queue based on Redis streams, without dependencies.

Extends the node redis client with readStream, writeStream, and writeThrough functions.

to produce and consume redis streams in non-blocking manner. ION-Streamer listens to streams in subprocess.

Durable Layer-2 messaging adapter: BullMQ job queue + Redis Streams event bus behind @agentback/messaging ports

Aggregate redis streams connections, powered by ioredis

> Typescript Consumer/Producer for Redis Streams

Production-oriented Redis palette for Node-RED: generic commands, Pub/Sub, scans, transactions, and Redis Streams consumer groups.

Distributed Command Bus library with Redis Streams transport, MessagePack serialization, and RPC via LPUSH/BRPOP for DragonflyDB

Redis Streams transport for @quanticjs/events-core — RedisStreamPublisher, RedisStreamConsumer

Redis Streams backed durable job queue primitives for Hile applications

This package is a broker to redis stream data type, This package provides guaranteed message delivery feature with acknowledgement.

A class for convenient work with reading and writing messages to redis streams.

Redis Streams transport for @miiajs/messaging - consumer groups, exponential backoff retry via ZSET, auto-DLQ, idempotency store.

High-performance Redis Streams queue for Node.js with Lua-powered bulk XADD, idempotent workers, heartbeat locks, stuck-task recovery, retries, DLQ, and distributed processing.

High-performance Redis Streams queue integration for NestJS based on power-queues.

CLI tool for monitoring Redis streams and PubSub

Reliable and modern Redis-Streams based task queue for Node.js

Redis-streams transport for clamator (pre-1.0).

This is a simple library for Redis Streams data type, which is used to accumulate messages until a specified threshold is reached, post which the same is available to consumer stream.

Reliable WebSocket protocol: client (reconnect, offline queue, ack) + server (Redis Streams seq/replay/dedup) + Elysia adapter. Browser and Bun/Node.