RabbitMqDeadLetterTransport
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:65
DeadLetterTransport backed by RabbitMQ (amqplib).
Publishes each dead letter as a persistent JSON message and waits for a
broker publisher-confirm acknowledgement before reporting success. Make sure
the target exchange/queue exists (channel.assertQueue(...)) before use.
Example
Section titled “Example”const conn = await amqp.connect(process.env.AMQP_URL);const channel = await conn.createConfirmChannel();await channel.assertQueue('dead-letters', { durable: true });const transport = new RabbitMqDeadLetterTransport(channel, { routingKey: 'dead-letters' });Implements
Section titled “Implements”Constructors
Section titled “Constructors”Constructor
Section titled “Constructor”new RabbitMqDeadLetterTransport(
channel,options?):RabbitMqDeadLetterTransport
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:70
Parameters
Section titled “Parameters”channel
Section titled “channel”options?
Section titled “options?”RabbitMqDeadLetterTransportOptions = {}
Returns
Section titled “Returns”RabbitMqDeadLetterTransport
Methods
Section titled “Methods”send()
Section titled “send()”send(
record):Promise<void>
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:84
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>