Skip to main content
Version: 2.x

Class: OutboxWorker

Defined in: javascript/src/storage/outbox-worker.ts:92

Generic leased-outbox dispatcher.

Handlers must be idempotent because a process can stop after the external write succeeds but before PostgreSQL records the acknowledgement.

Constructors​

Constructor​

new OutboxWorker(store, handlers, options?): OutboxWorker

Defined in: javascript/src/storage/outbox-worker.ts:102

Parameters​

store​

OutboxStore

handlers​

readonly OutboxHandler[]

options?​

OutboxWorkerOptions = {}

Returns​

OutboxWorker

Methods​

runOnce()​

runOnce(): Promise<OutboxRunResult>

Defined in: javascript/src/storage/outbox-worker.ts:147

Returns​

Promise<OutboxRunResult>

start()​

start(): Promise<void>

Defined in: javascript/src/storage/outbox-worker.ts:132

Returns​

Promise<void>

stop()​

stop(): Promise<void>

Defined in: javascript/src/storage/outbox-worker.ts:139

Returns​

Promise<void>