Connectum API Reference / @connectum/events-redis / RedisAdapter

Function: RedisAdapter()

RedisAdapter(options?): EventAdapter

Defined in: RedisAdapter.ts:68

Create a Redis Streams adapter for the Connectum event bus.

The adapter uses Redis Streams with consumer groups for durable, load-balanced event consumption. Each subscription creates a dedicated blocking connection (via redis.duplicate()) to avoid blocking the main connection used for publishing.

Parameters

options?

RedisAdapterOptions = {}

Returns

EventAdapter

Example

import { createEventBus } from "@connectum/events";
import { RedisAdapter } from "@connectum/events-redis";

const bus = createEventBus({
    adapter: RedisAdapter({ url: "redis://localhost:6379" }),
    routes: [myEventRoutes],
});

await bus.start();