Skip to content

eventQueueMessageSchema

const eventQueueMessageSchema: ZodObject<{ events: ZodArray<ZodObject<{ eventId: ZodUUID; identity: ZodRecord<ZodString, ZodString>; occurredAtUs: ZodString; payload: ZodUnknown; }, $strict>>; stream: ZodString; }, $strict>

Defined in: packages/contracts/src/events.ts:140

One queue message: a single-stream sub-batch. The endpoint splits a mixed flush batch by Event stream (preserving array order) and enqueues each sub-batch as ONE message on that stream’s queue — one visibility timeout, one ack, one consumer transaction per message. Events arrive at the callback in append order WITHIN a message; across messages there is no ordering promise (ADR-0053 decision 6).