DeadLetterRedriver

Defined in: packages/pipeline-deadletter/src/dead-letter.redriver.ts:71

Redrives dead letters kept by a DeadLetterStore: rebuilds the request, dispatches it, then marks the record resolved — or, when the handling fails again, counts the attempt, keeps its error, and rethrows it. During a redrive, DeadLetterBehavior neither captures the failure again nor swallows it.

The application supplies the dispatch functions, one per request kind:

Example

const redriver = new DeadLetterRedriver(store, {
  requestTypes: [SendWelcomeEmailCommand, UserCreatedEvent],
  dispatch: {
    command: (command) => commands.execute(command),
    // Only the failed handler, not every subscriber of the event.
    event: (event, record) => eventHandlers[record.handlerName](event),
  },
});
await redriver.redrive(recordId);