Pattern 3 producer-side outbox drainer for the Nodii microservice stack — defineDispatcher + startDispatcher + single-active SET-NX-EX lease (D209) + FOR UPDATE SKIP LOCKED drain + XADD to Redis Streams + currentHwm + 24h-unpublished ops-alert sweep (D401

Redis store adapter for nvent using Redis Streams

Topic-Based Messaging Queue on top of Redis Streams

Multi-agent orchestration for Claude Code via Redis streams and MCP

`@jetit/publisher` is a robust and feature-rich library for implementing an event-driven architecture using Redis PUB/SUB and Redis Streams. It provides a scalable mechanism for publishing and consuming events in real-time, with support for advanced featu

 

Redis Streams Transport for NestJS

Shared auth for TheJob services: Better Auth JWT verification middleware + user lifecycle events over Redis Streams.

a message queue by redis streams

Shared Redis Streams messaging (publisher + consumer-group utility) for Nipige services

The Socket.IO adapter based on Redis Streams, allowing to broadcast events between several Socket.IO servers

Redis Streams transport for saga-bus

Notification pipeline contract + client for The Job: domain services emit facts over Redis Streams, the notification-service turns them into mail.

Clean Redis Streams messages that are were already read by all consumer groups

Domain events for quanticjs — outbox pattern, Redis Streams pub/sub

Framework-agnostic realtime primitives powered by Redis Streams.

A simple redis-streams consumer package with auto ack

Pub/Sub trigger for Blok workflows — supports NATS (Core + JetStream), Redis Streams, Kafka, GCP Pub/Sub, AWS SNS+SQS, and Azure Service Bus.

Node-RED nodes for OCPP (Open Charge Point Protocol) message handling via Redis Streams

Lightweight event bus for Node.js microservices powered by Redis Streams.