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

method NatsBroker.prototype.subscribe

Since 0.1.0



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

Subscribes to a topic using JetStream durable consumers.

Type Parameters

The message payload type



topic: string

The subject to subscribe to



handler: MessageHandler<T>

The handler to invoke for each message

optional



options: SubscribeOptions

Optional subscription options (queue for durable consumer name)

Promise<ISubscription>

The subscription handle

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