Skip to content

EventConsumerCallback

EventConsumerCallback = (batch) => void | Promise<void>

Defined in: packages/server/src/events/consumer.ts:139

The consumer callback. Returning (resolving) ACKS the sub-batch; THROWING retries it — the message stays invisible until its visibility timeout lapses and the queue redelivers it.

It MUST be idempotent (ADR-0053 decision 6, at-least-once): the blessed pattern is deduping on eventId against the app’s own durable store, which composes to effectively-exactly-once.

EventConsumerBatch

void | Promise<void>