Interface ConnectionChannel

A type alias for a channel that can be either a regular amqplib.Channel or a amqplib.ConfirmChannel.

Hierarchy

  • ConnectionChannel

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 ConnectionChannel.