Persist events with sendEventStore and replay them with subscribeToEventsStore, supplying startFrom and startValue fields.

sendEventStore

await client.sendEventStore(message: EventStoreMessage): Promise<EventStoreResult>

Returns: EventStoreResult — broker acknowledgement metadata.

subscribeToEventsStore

client.subscribeToEventsStore(subscription: EventStoreSubscription): Subscription

Adds startFrom and startValue fields for replay configuration.

events.ts

await client.sendEventStore(
  createEventStoreMessage({ channel: "audit", body: Buffer.from("record") }),
);