IMessageBroker.subscribe - common/src/index.ts

method IMessageBroker.subscribe



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

Subscribes to a topic.

Type Parameters

The payload type



topic: string

Source topic



handler: MessageHandler<T>

Invoked per delivered message

optional



options: SubscribeOptions

Consumer group behavior

Promise<ISubscription>

The active subscription