Skip to main content

OutboxStore

@totemsdk/edge

@totemsdk/edge / OutboxStore

Interface: OutboxStore

A durable outbox store.

Methods​

enqueue()​

enqueue(entry): Promise<void>

Atomically enqueue an outbound message.

Parameters​

entry​

OutboxEntry

Returns​

Promise<void>

listUndelivered()​

listUndelivered(): Promise<OutboxEntry[]>

List undelivered entries (for resend on restart).

Returns​

Promise<OutboxEntry[]>

markDelivered()​

markDelivered(messageId, deliveredAt): Promise<void>

Mark a message as delivered.

Parameters​

messageId​

string

deliveredAt​

number

Returns​

Promise<void>

recordAttempt()​

recordAttempt(messageId): Promise<void>

Increment the delivery attempt count.

Parameters​

messageId​

string

Returns​

Promise<void>