Interface ConnectionConfirmChannel

An interface that extends the amqplib.ConfirmChannel interface and adds an array of unconfirmed callbacks.

Hierarchy

  • ConfirmChannel
    • ConnectionConfirmChannel

Properties

accept: Function

A function that is used to send a message to the queue.

Remarks

This is only defined here so we can manually monkey patch it when we are closing down the channel

pending: unknown[]

An array that holds the pending rpc messsages for the queue's channel.

reply: any

A reply object that is used for RPC messages, or null if there's nothing

Remarks

This is only defined here so we can manually clear it when we are closing down the channel

An array of callbacks or nulls for a ConnectionConfirmChannel. Each item is a callback that is called when a message is confirmed or null if the message is not confirmed.