retort

v2.7.0

retort v2.7.0 Retort.Channel View Source

Establishes a channel

Link to this section Summary

Types

queue()

The name of a RabbitMQ queue

Functions

ensure_closed(channel)

Closes the channel if it is not already closed

init(queue, amqp \\ Retort.AMQP.Default)

Opens a new channel on queue with the calling process as the consumer

Link to this section Types

Link to this type queue() View Source 
queue() :: String.t()

The name of a RabbitMQ queue

Link to this section Functions

Link to this function ensure_closed(channel) View Source 
ensure_closed(%AMQP.Channel{conn: term(), pid: term()}) ::
  :already_closed |
  :ok

Closes the channel if it is not already closed

Link to this function init(queue, amqp \\ Retort.AMQP.Default) View Source 
init(queue(), module()) :: {:ok, %AMQP.Channel{conn: term(), pid: term()}}

Opens a new channel on queue with the calling process as the consumer