View Source AMQP.Channel (amqp v4.0.0)
Functions to operate on Channels.
Summary
Types
@type t() :: %AMQP.Channel{ conn: AMQP.Connection.t(), custom_consumer: custom_consumer() | nil, pid: pid() }
Functions
@spec close(t()) :: :ok | {:error, AMQP.Basic.error()}
Closes an open Channel.
@spec open(AMQP.Connection.t(), custom_consumer() | nil) :: {:ok, t()} | {:error, any()}
Opens a new Channel in a previously opened Connection.
Allows optionally to pass a custom_consumer/0
to start a custom consumer
implementation. The consumer must implement the :amqp_gen_consumer
behavior
from :amqp_client
. See :amqp_connection.open_channel/2
for more details
and AMQP.DirectConsumer
for an example of a custom consumer.