interface SubscriptionDefinition
Since 0.3.0

The declarative form of one IMessageBroker.subscribe() call — the entry an application writes instead of calling subscribe() imperatively after start().

Properties

readonly
topic: string

The topic to subscribe to (the subscribe() topic argument).

Invoked per delivered message, exactly as the imperative subscribe() accepts.

readonly
optional
options: SubscribeOptions

Consumer-group configuration, exactly as the imperative subscribe() accepts.

Usage

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