Skip to main content
Version: 2.x

Interface: OutboxRecoveryStore

Defined in: javascript/src/storage/ports.ts:65

Extends​

Methods​

claim()​

claim(topics, limit, leaseSeconds): Promise<OutboxEvent[]>

Defined in: javascript/src/storage/ports.ts:19

Parameters​

topics​

readonly string[]

limit​

number

leaseSeconds​

number

Returns​

Promise<OutboxEvent[]>

Inherited from​

OutboxStore.claim

complete()​

complete(event): Promise<boolean>

Defined in: javascript/src/storage/ports.ts:20

Parameters​

event​

OutboxEvent

Returns​

Promise<boolean>

Inherited from​

OutboxStore.complete

fail()​

fail(event, error, retryDelaySeconds, attemptLimit): Promise<boolean>

Defined in: javascript/src/storage/ports.ts:21

Parameters​

event​

OutboxEvent

error​

string

retryDelaySeconds​

number

attemptLimit​

number

Returns​

Promise<boolean>

Inherited from​

OutboxStore.fail

listDeadLetters()​

listDeadLetters(options?): Promise<OutboxDeadLetterPage>

Defined in: javascript/src/storage/ports.ts:67

Parameters​

options?​

OutboxDeadLetterListOptions

Returns​

Promise<OutboxDeadLetterPage>

renew()​

renew(event, leaseSeconds): Promise<boolean>

Defined in: javascript/src/storage/ports.ts:15

Parameters​

event​

OutboxEvent

leaseSeconds​

number

Returns​

Promise<boolean>

Inherited from​

OutboxStore.renew

requeue()​

requeue(eventId): Promise<boolean>

Defined in: javascript/src/storage/ports.ts:68

Parameters​

eventId​

string

Returns​

Promise<boolean>

stats()​

stats(): Promise<OutboxStats>

Defined in: javascript/src/storage/ports.ts:66

Returns​

Promise<OutboxStats>