View Source AMQP.Channel (amqp v3.3.0)

Functions to operate on Channels.

Link to this section Summary

close(channel)

Closes an open Channel.

Opens a new Channel in a previously opened Connection.

@type custom_consumer() :: {module(), args :: any()}

@type t() :: %AMQP.Channel{
  conn: AMQP.Connection.t(),
  custom_consumer: custom_consumer() | nil,
  pid: pid()
}

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