RabbitMqConfirmChannelLike
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:13
Minimal structural shape of an amqplib ConfirmChannel. Declared locally
so this package does not hard-depend on amqplib. Add it in your app with
pnpm add amqplib and create it via connection.createConfirmChannel().
Methods
Section titled “Methods”once()?
Section titled “once()?”
optionalonce(event,listener):unknown
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:23
EventEmitter lifecycle hook exposed by real amqplib channels.
Parameters
Section titled “Parameters”"drain" | "close" | "error"
listener
Section titled “listener”(error?) => void
Returns
Section titled “Returns”unknown
publish()
Section titled “publish()”publish(
exchange,routingKey,content,options?):boolean
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:14
Parameters
Section titled “Parameters”exchange
Section titled “exchange”string
routingKey
Section titled “routingKey”string
content
Section titled “content”Buffer
options?
Section titled “options?”unknown
Returns
Section titled “Returns”boolean
removeListener()?
Section titled “removeListener()?”
optionalremoveListener(event,listener):unknown
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:28
Removes lifecycle listeners after the backpressure wait settles.
Parameters
Section titled “Parameters”"drain" | "close" | "error"
listener
Section titled “listener”(error?) => void
Returns
Section titled “Returns”unknown
waitForConfirms()
Section titled “waitForConfirms()”waitForConfirms():
Promise<void>
Defined in: packages/pipeline-deadletter/src/transports/rabbitmq.transport.ts:21
Waits until the broker acknowledges or rejects all outstanding publishes.
Returns
Section titled “Returns”Promise<void>