Delivery

Defined in: src/delivery/Messages.ts:8

Wire-shape sent from Producer to Consumer. Each envelope carries the producer id (used by consumers to dedup across producers) and a monotonically increasing sequence number per producer-consumer pair.

Type Parameters

T

T

Properties

body

readonly body: T

Defined in: src/delivery/Messages.ts:12

---

kind

readonly kind: "reliable-delivery.delivery"

Defined in: src/delivery/Messages.ts:9

---

producerId

readonly producerId: string

Defined in: src/delivery/Messages.ts:10

---

replyTo

readonly replyTo: ActorRef<Ack>

Defined in: src/delivery/Messages.ts:14

Reply address — the consumer Acks back here.

---

seq

readonly seq: number

Defined in: src/delivery/Messages.ts:11