RedisStreamsBroker.prototype.subscribe - messaging-plugin/src/index.ts

method RedisStreamsBroker.prototype.subscribe

Since 0.1.0



RedisStreamsBroker.prototype.subscribe<T>(topic: string,
handler: MessageHandler<T>,
options?: SubscribeOptions
): Promise<ISubscription>

Subscribes to a topic using Redis Streams consumer groups.

Type Parameters

The message payload type



topic: string

The topic (stream name) to subscribe to



handler: MessageHandler<T>

The handler to invoke for each message

optional



options: SubscribeOptions

Optional subscription options (queue for consumer group)

Promise<ISubscription>

The subscription handle

import { RedisStreamsBroker } from "messaging-plugin/src/index.ts";