Skip to main content

InMemoryOutboxStore

@totemsdk/edge

@totemsdk/edge / InMemoryOutboxStore

Class: InMemoryOutboxStore

In-memory outbox (dev/test).

Implements​

Constructors​

Constructor​

new InMemoryOutboxStore(): InMemoryOutboxStore

Returns​

InMemoryOutboxStore

Methods​

enqueue()​

enqueue(entry): Promise<void>

Atomically enqueue an outbound message.

Parameters​

entry​

OutboxEntry

Returns​

Promise<void>

Implementation of​

OutboxStore.enqueue

listUndelivered()​

listUndelivered(): Promise<OutboxEntry[]>

List undelivered entries (for resend on restart).

Returns​

Promise<OutboxEntry[]>

Implementation of​

OutboxStore.listUndelivered

markDelivered()​

markDelivered(messageId, deliveredAt): Promise<void>

Mark a message as delivered.

Parameters​

messageId​

string

deliveredAt​

number

Returns​

Promise<void>

Implementation of​

OutboxStore.markDelivered

recordAttempt()​

recordAttempt(messageId): Promise<void>

Increment the delivery attempt count.

Parameters​

messageId​

string

Returns​

Promise<void>

Implementation of​

OutboxStore.recordAttempt