Skip to content

SubscribeRequest

Internal subscribe request passed from the router to transports.

optional concurrency?: number

Maximum concurrent deliveries requested from the transport.

SubscribeOptions.concurrency


optional consumerGroup?: string

Consumer group or durable subscription identifier owned by the transport.

SubscribeOptions.consumerGroup


optional contextValues?: ContextValues

Context values passed through the interceptor chain and to nested operations.

SubscribeOptions.contextValues


optional deadLetterTopic?: string

Broker dead-letter topic resolved by the router, when any.


optional maxAttempts?: number

Maximum one-based delivery attempts before a retry disposition is converted to a dead-letter disposition by the transport. Unset means no transport-enforced limit.

SubscribeOptions.maxAttempts


optional signal?: AbortSignal

Optional cancellation signal for stopping long-running subscriptions.

SubscribeOptions.signal


topics: string[]

Broker topics or subjects resolved by the router.