ProducerControllerOptionsType

ProducerControllerOptionsType<T> = object

Defined in: src/delivery/ProducerControllerOptions.ts:7

Plain options-object shape accepted by a ProducerController.

Type Parameters

T

T

Properties

consumer

readonly consumer: ActorRef<Delivery<T>>

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

---

producerId?

readonly optional producerId?: string

Defined in: src/delivery/ProducerControllerOptions.ts:20

Stable identifier used by consumers to dedup across restarts.

---

resendTimeout?

readonly optional resendTimeout?: number

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

How long to wait for an Acknowledgment before re-sending. Default 500ms.

---

windowSize?

readonly optional windowSize?: number

Defined in: src/delivery/ProducerControllerOptions.ts:18

Flow-control window: at most windowSize messages may be in-flight (un-acked) at any moment. Additional Sends queue until room opens up. Default: 16.