retort

v2.7.0

retort v2.7.0 Retort.Queue View Source

Extensions to AMQP.Queue

Link to this section Summary

Types

t()

The name of a queue

Functions

ensure_deleted(queue, channel)

Deletes queue if it exists

exists?(queue, channel)

Whether queue exists

Link to this section Types

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

The name of a queue

Link to this section Functions

Link to this function ensure_deleted(queue, channel) View Source 
ensure_deleted(String.t(), %AMQP.Channel{conn: term(), pid: term()}) ::
  :ok |
  :already_deleted |
  {:error, :channel_closed}

Deletes queue if it exists

Link to this function exists?(queue, channel) View Source 
exists?(t(), %AMQP.Channel{conn: term(), pid: term()}) :: boolean()

Whether queue exists