ReliableDelivery
Defined in: src/delivery/ReliableDelivery.ts:41
Point-to-point at-least-once delivery between a Producer and a Consumer. Messages are assigned monotonic sequence numbers; the consumer Acks back after handling, the producer retries on timeout, and duplicates are silently absorbed on the consumer side.
For work-pulling (multiple consumers, one producer) see the WorkPulling companion (follow-up feature).
Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new ReliableDelivery():
ReliableDelivery
Returns
Section titled “Returns”ReliableDelivery
Methods
Section titled “Methods”consumer()
Section titled “consumer()”
staticconsumer<T>(system,settings,name?):ConsumerHandle
Defined in: src/delivery/ReliableDelivery.ts:43
Spawn a ConsumerController — pass the returned ref to a ProducerController.
Type Parameters
Section titled “Type Parameters”T
Parameters
Section titled “Parameters”system
Section titled “system”settings
Section titled “settings”string
Returns
Section titled “Returns”producer()
Section titled “producer()”
staticproducer<T>(system,settings,name?):ProducerHandle<T>
Defined in: src/delivery/ReliableDelivery.ts:56
Spawn a ProducerController aimed at settings.consumer.
Type Parameters
Section titled “Type Parameters”T
Parameters
Section titled “Parameters”system
Section titled “system”settings
Section titled “settings”string