method IServiceBusTransport.open
IServiceBusTransport.open(
topic: string,
subscription: string,
onMessage: (msg: { payload: string; ack: () => void; nack: () => void; applicationProperties?: Readonly<Record<string, string>>; messageId?: string; timestamp?: Date; }) => void | Promise<void>
): Promise<IServiceBusSubscription>

Open a receiver on a topic subscription.

Parameters

topic: string
subscription: string
onMessage: (msg: { payload: string; ack: () => void; nack: () => void; applicationProperties?: Readonly<Record<string, string>>; messageId?: string; timestamp?: Date; }) => void | Promise<void>

Called per delivered message

Return Type

Usage

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