ex_rabbit_pool

v1.0.3

ex_rabbit_pool v1.0.3 ExRabbitPool.Clients.Adapter behaviour View Source

Link to this section Summary

Callbacks

ack(arg1, arg2, keyword)
cancel_consume(arg1, arg2, keyword)
close_channel(arg1)
close_connection(arg1)
consume(arg1, arg2, arg3, keyword)
declare_exchange(arg1, arg2, keyword)
declare_queue(arg1, arg2, keyword)
open_channel(arg1)
open_connection(arg1)
publish(arg1, arg2, arg3, arg4, keyword)
qos(arg1, keyword)
queue_bind(arg1, arg2, arg3, keyword)
reject(arg1, arg2, keyword)

Link to this section Callbacks

Link to this callback

ack(arg1, arg2, keyword) View Source 
ack(AMQP.Channel.t(), String.t(), keyword()) :: :ok | AMQP.Basic.error()

Link to this callback

cancel_consume(arg1, arg2, keyword) View Source 
cancel_consume(AMQP.Channel.t(), String.t(), keyword()) ::
  {:ok, String.t()} | {:error, AMQP.Basic.error()}

Link to this callback

close_channel(arg1) View Source 
close_channel(AMQP.Channel.t() | pid()) :: :ok | {:error, AMQP.Basic.error()}

Link to this callback

close_connection(arg1) View Source 
close_connection(AMQP.Connection.t()) :: :ok | {:error, any()}

Link to this callback

consume(arg1, arg2, arg3, keyword) View Source 
consume(AMQP.Channel.t(), String.t(), pid() | nil, keyword()) ::
  {:ok, String.t()} | AMQP.Basic.error()

Link to this callback

declare_exchange(arg1, arg2, keyword) View Source 
declare_exchange(AMQP.Channel.t(), AMQP.Basic.exchange(), keyword()) ::
  :ok | AMQP.Basic.error()

Link to this callback

declare_queue(arg1, arg2, keyword) View Source 
declare_queue(AMQP.Channel.t(), AMQP.Basic.queue(), keyword()) ::
  {:ok, map()} | AMQP.Basic.error()

Link to this callback

open_channel(arg1) View Source 
open_channel(AMQP.Connection.t()) ::
  {:ok, AMQP.Channel.t()} | {:error, any()} | any()

Link to this callback

open_connection(arg1) View Source 
open_connection(keyword() | String.t()) ::
  {:ok, AMQP.Connection.t()} | {:error, any()}

Link to this callback

publish(arg1, arg2, arg3, arg4, keyword) View Source 
publish(AMQP.Channel.t(), String.t(), String.t(), String.t(), keyword()) ::
  :ok | AMQP.Basic.error()

Link to this callback

qos(arg1, keyword) View Source 
qos(AMQP.Channel.t(), keyword()) :: :ok | AMQP.Basic.error()

Link to this callback

queue_bind(arg1, arg2, arg3, keyword) View Source 
queue_bind(
  AMQP.Channel.t(),
  AMQP.Basic.queue(),
  AMQP.Basic.exchange(),
  keyword()
) :: :ok | AMQP.Basic.error()

Link to this callback

reject(arg1, arg2, keyword) View Source 
reject(AMQP.Channel.t(), String.t(), keyword()) :: :ok | AMQP.Basic.error()