Skip to content

SubscribeRequest

Defined in: packages/pubsub/src/types.ts:104

Internal subscribe request passed from the router to transports.

optional concurrency?: number

Defined in: packages/pubsub/src/types.ts:91

Maximum concurrent deliveries requested from the transport.

SubscribeOptions.concurrency


optional consumerGroup?: string

Defined in: packages/pubsub/src/types.ts:89

Consumer group or durable subscription identifier owned by the transport.

SubscribeOptions.consumerGroup


optional contextValues?: ContextValues

Defined in: packages/pubsub/src/types.ts:100

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

SubscribeOptions.contextValues


optional deadLetterTopic?: string

Defined in: packages/pubsub/src/types.ts:108

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


optional maxAttempts?: number

Defined in: packages/pubsub/src/types.ts:96

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

Defined in: packages/pubsub/src/types.ts:98

Optional cancellation signal for stopping long-running subscriptions.

SubscribeOptions.signal


topics: string[]

Defined in: packages/pubsub/src/types.ts:106

Broker topics or subjects resolved by the router.