Skip to main content

JetstreamConsumeContext

@horizon-republic/nestjs-jetstream


@horizon-republic/nestjs-jetstream / JetstreamConsumeContext

JetstreamConsumeContext

Defined in: src/otel/config.ts:70

Context passed to OtelOptions.consumeHook for an incoming dispatch.

Properties​

handlerMetadata​

readonly handlerMetadata: HandlerMetadata

Defined in: src/otel/config.ts:83

Handler metadata; see HandlerMetadata.


kind​

readonly kind: ConsumeKind

Defined in: src/otel/config.ts:86

Classification of the incoming operation.


msg​

readonly msg: ConsumeSourceMsg

Defined in: src/otel/config.ts:80

The incoming NATS message. JetStream messages (events, broadcast, ordered, JetStream RPC) satisfy JsMsg; Core RPC messages satisfy the looser ConsumeSourceMsg shape only. Narrow on kind to decide which fields are safe to access.


subject​

readonly subject: string

Defined in: src/otel/config.ts:72

Fully-resolved subject of the incoming message.