JetStreamCmd

JetStreamCmd = { kind: "publish"; publish: JetStreamPublish; } | { kind: "ack"; streamSeq: number; } | { delayMs?: number; kind: "nak"; streamSeq: number; } | { kind: "term"; reason?: string; streamSeq: number; } | { kind: "inProgress"; streamSeq: number; } | { batch: number; expiresMs?: number; kind: "fetch"; }

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

Union Members

Type Literal

{ kind: "publish"; publish: JetStreamPublish; }

---

Type Literal

{ kind: "ack"; streamSeq: number; }

Acknowledge a delivered message — server marks consumed.

---

Type Literal

{ delayMs?: number; kind: "nak"; streamSeq: number; }

Negative-ack — server redelivers (after optional delayMs).

---

Type Literal

{ kind: "term"; reason?: string; streamSeq: number; }

Terminal failure — server drops the message permanently.

---

Type Literal

{ kind: "inProgress"; streamSeq: number; }

Heartbeat — extend the ack-wait window for a long-running handler.

---

Type Literal

{ batch: number; expiresMs?: number; kind: "fetch"; }

Pull-mode (#62) — fetch up to batch messages, returning early after expiresMs (default 5 s) if fewer are available. Each fetched message still goes through the same ack/nak/term handshake as push-mode. Sending fetch to a push-mode consumer is a silent no-op with a warn log.