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

method GcpPubSubBroker.prototype.subscribe



GcpPubSubBroker.prototype.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

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