retort

v2.7.0

retort v2.7.0 Retort.AMQP behaviour View Source

Wrap AMQP.* modules so only functions needed for Retort.Channel are exposed, so it can be swapped during tests of error handling

Link to this section Summary

Types

queue()

The name of a RabbitMQ queue

Callbacks

consume(%, queue)
declare_queue(%, queue)
open(%)
prefetch_count(%, non_neg_integer)

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 Callbacks

Link to this callback consume(%, queue) View Source 
consume(%AMQP.Channel{conn: term(), pid: term()}, queue()) :: {:ok, term()}
Link to this callback declare_queue(%, queue) View Source 
declare_queue(%AMQP.Channel{conn: term(), pid: term()}, queue()) :: {:ok, %{queue: Retort.AMQP.queue(), message_count: non_neg_integer(), consumer_count: non_neg_integer()}}
Link to this callback open(%) View Source 
open(%AMQP.Connection{pid: term()}) :: {:ok, %AMQP.Channel{conn: term(), pid: term()}}
Link to this callback prefetch_count(%, non_neg_integer) View Source 
prefetch_count(%AMQP.Channel{conn: term(), pid: term()}, non_neg_integer()) :: :ok