Skip to main content

Usage

subscription.on(async (event) => {
  if (!isValidOrder(event.payload)) {
    await subscription.discard(event.idem, "Invalid order data");
    return;
  }

  await processOrder(event.payload);
  await subscription.ack(event.idem, event.block);
});

Parameters

ParameterTypeRequiredDescription
idemstringYesUnique event ID
reasonstringNoOptional reason for discarding
Discarded events cannot be recovered. Use defer for temporary failures.