Interface: OutboxRecoveryStore

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

Extends

• OutboxStore

Methods

claim()

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

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

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:22

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:23

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:69

Parameters

options?

OutboxDeadLetterListOptions

Returns

Promise<OutboxDeadLetterPage>

---

renew()

renew(event, leaseSeconds): Promise<boolean>

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

Parameters

event

OutboxEvent

leaseSeconds

number

Returns

Promise<boolean>

Inherited from

OutboxStore.renew

---

requeue()

requeue(eventId): Promise<boolean>

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

Parameters

eventId

string

Returns

Promise<boolean>

---

stats()

stats(options?): Promise<OutboxStats>

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

Parameters

options?

limit?

number

Returns

Promise<OutboxStats>