Skip to content

JetStreamMessage

Defined in: src/io/broker/JetStreamActor.ts:69

Inbound JetStream message handed to subscribers.

readonly consumerSeq: number

Defined in: src/io/broker/JetStreamActor.ts:77

Consumer delivery sequence — bumps on every (re-)delivery.


readonly deliveries: number

Defined in: src/io/broker/JetStreamActor.ts:79

Number of times this message has been delivered (1 = first try).


readonly headers: Readonly<Record<string, string>>

Defined in: src/io/broker/JetStreamActor.ts:83

Optional per-message headers (e.g. Nats-Msg-Id).


readonly payload: Uint8Array

Defined in: src/io/broker/JetStreamActor.ts:71


readonly replyTo: string

Defined in: src/io/broker/JetStreamActor.ts:73

Reply subject (for request/reply patterns); empty when not set.


readonly streamSeq: number

Defined in: src/io/broker/JetStreamActor.ts:75

Stream sequence — unique within the stream, monotonic per stream.


readonly subject: string

Defined in: src/io/broker/JetStreamActor.ts:70


readonly timestamp: number

Defined in: src/io/broker/JetStreamActor.ts:81

Server-assigned timestamp in ms since epoch.