Class MemoryOutboxStore

An outbox store in memory (tests; not durable).

Implements

OutboxStore

Index

Constructors

Methods

add close failed mark pending

Constructors

constructor

new MemoryOutboxStore(): MemoryOutboxStore
Returns MemoryOutboxStore

Methods

add

add(entry: OutboxEntry): Promise<OutboxEntry>
Stores entry with the next entryId.
Parameters
- entry: OutboxEntry
  The entry.
Returns Promise<OutboxEntry>
The stored entry.

Throws
Error when the key is already stored.

Implementation of OutboxStore.add

close

close(): Promise<void>
Nothing to release.

Returns Promise<void>
Implementation of OutboxStore.close

failed

failed(): Promise<OutboxEntry[]>
Returns the failed entries in order.

Returns Promise<OutboxEntry[]>
The entries.

Implementation of OutboxStore.failed

mark

mark(entryId: number, state: OutboxState, problemCode?: string): Promise<void>
Changes the state of an entry; sent deletes it.
Parameters
- entryId: number
  The entry.
- state: OutboxState
  The new state.
- OptionalproblemCode: string
  The problem code of a failed entry.
Returns Promise<void>
Implementation of OutboxStore.mark

pending

pending(): Promise<OutboxEntry[]>
Returns the pending entries in order.

Returns Promise<OutboxEntry[]>
The entries.

Implementation of OutboxStore.pending