DeadLetterTransport
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:76
Transport-agnostic sink for dead letters.
Implement this once per backend; the bundled implementations are BullMqDeadLetterTransport, RabbitMqDeadLetterTransport, and PostgresDeadLetterTransport. Because the DeadLetterBehavior depends only on this interface, swapping the backend is a one-line change: the transport passed to its constructor.
Extended by
Section titled “Extended by”Methods
Section titled “Methods”send()
Section titled “send()”send(
record):Promise<void>
Defined in: packages/pipeline-deadletter/src/interfaces/dead-letter-transport.interface.ts:85
Persist / publish a single dead-letter record.
Implementations should be resilient and fast; a throw here is caught by the behavior and logged, but never masks the original handler error.
Parameters
Section titled “Parameters”record
Section titled “record”The failed request snapshot to forward.
Returns
Section titled “Returns”Promise<void>