Skip to content
actor-ts

ProducerControllerSettings

Defined in: src/delivery/ProducerController.ts:16

Type Parameters

Section titled “Type Parameters”

T

Section titled “T”

T

Properties

Section titled “Properties”

consumer

Section titled “consumer”

readonly consumer: ActorRef<Delivery<T>>

Defined in: src/delivery/ProducerController.ts:17

producerId?

Section titled “producerId?”

readonly optional producerId?: string

Defined in: src/delivery/ProducerController.ts:29

Stable identifier used by consumers to dedup across restarts.

resendTimeoutMs?

Section titled “resendTimeoutMs?”

readonly optional resendTimeoutMs?: number

Defined in: src/delivery/ProducerController.ts:21

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

windowSize?

Section titled “windowSize?”

readonly optional windowSize?: number

Defined in: src/delivery/ProducerController.ts:27

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.