A function that is used to send a message to the queue.
This is only defined here so we can manually monkey patch it when we are closing down the channel
An array that holds the pending rpc messsages for the queue's channel.
A reply object that is used for RPC messages, or null if there's nothing
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 ConnectionBasicChannel.
Each item is a callback that is called when a message is confirmed or null if the message is not confirmed.
An interface that extends the
amqplib.Channelinterface and adds an array of unconfirmed callbacks.