Skip to content
actor-ts

JetStreamPublish

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

Outbound JetStream publish — payload + optional dedupe headers.

Properties

Section titled “Properties”

expectedLastSeq?

Section titled “expectedLastSeq?”

readonly optional expectedLastSeq?: number

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

Optional expected last sequence — server rejects the publish if the stream’s last seq doesn’t match (optimistic concurrency).

headers?

Section titled “headers?”

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

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

Extra headers (free-form).

messageId?

Section titled “messageId?”

readonly optional messageId?: string

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

Optional dedupe id — sent as Nats-Msg-Id header so a re-publish within the stream’s deduplication window is idempotent.

payload

Section titled “payload”

readonly payload: string | Uint8Array<ArrayBufferLike>

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

subject

Section titled “subject”

readonly subject: string

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