Xivi-Track - Publish to Xap pages
Redis Streams Library for Node.js/Typescript with full consumer group recovery
Distributed Command Bus library with Redis Streams transport, MessagePack serialization, and RPC via LPUSH/BRPOP for DragonflyDB
Redis Streams Library for Node.js/Typescript with full consumer group recovery
Redis Streams-based transporter for NestJS microservices, enabling message passing via Redis Streams
redis-stream curd
Redis Streams transport for saga-bus
Durable, tenant-isolated execution context for Octaviaflow workflow engine — typed step envelopes, ExecutionContextStore (Valkey-backed), n-th level JSON Schema inferencer, and idempotent execution-event stream
Redis adapter for [kai](https://github.com/kairos-computer/kai) — provides ready-made implementations of kai's Streaming, MessageQueue, and StopSignal services using [ioredis](https://github.com/redis/ioredis).
a message queue by redis streams
Redis Streams transport for @schally/nestjs-messenger (not BullMQ — see ADR-003).
Robust Redis Stream based message queue with auto-claim and retry handling / 基于 Redis Stream 的健壮消息队列，支持自动认领和重试处理
Platform source plugin for Drasi
Redis Streams-backed task queue with a derive macro for automatic struct ↔ redis::Value mapping. Supports tokio and smol.
Standalone background processor binaries for the Affinidi Messaging Mediator (Redis-only, horizontal scaling)
The fastest open-source message broker for Redis. Rust-native engine on Redis Streams + MessagePack, with Node.js and Python bindings.
High-performance Redis-compatible server on redb with vector database support
A simple message queue library for Rust.
🌊 The stream processing toolkit for Rust
🌊 SeaStreamer Redis Backend
A high-performance, memory-safe key-value store
Waypoint is a Farcaster synchronization tool built in Rust, optimized for memory efficiency.