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

method RabbitMqBroker.prototype.subscribe

Since 0.1.0



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

Subscribes to a topic.

Type Parameters

The message payload type



topic: string

The topic 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 { RabbitMqBroker } from "messaging-plugin/src/index.ts";