BullMqDeadLetterTransport
Defined in: packages/pipeline-deadletter/src/transports/bullmq.transport.ts:50
Bundled DeadLetterTransport backed by a BullMQ queue.
Each dead letter is added as a job; a worker (or Bull Board) can then inspect,
alert on, or replay it. The constructor takes any object matching
BullMqQueueLike, so a real bullmq Queue works directly. Nothing
selects this transport implicitly; pass an instance to the
DeadLetterBehavior constructor.
Example
Section titled “Example”import { Queue } from 'bullmq';const queue = new Queue('dead-letters', { connection: { host, port } });const transport = new BullMqDeadLetterTransport(queue);Implements
Section titled “Implements”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new BullMqDeadLetterTransport(
queue,options?):BullMqDeadLetterTransport
Defined in: packages/pipeline-deadletter/src/transports/bullmq.transport.ts:54
Parameters
Section titled “Parameters”options?
Section titled “options?”BullMqDeadLetterTransportOptions = {}
Returns
Section titled “Returns”BullMqDeadLetterTransport
Methods
Section titled “Methods”send()
Section titled “send()”send(
record):Promise<void>
Defined in: packages/pipeline-deadletter/src/transports/bullmq.transport.ts:62
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>