ex_rabbit_pool

v1.0.3

ex_rabbit_pool v1.0.3 ExRabbitPool.Worker.RabbitConnection View Source

Link to this section Summary

Functions

checkin_channel(pid, channel)
checkout_channel(pid)
child_spec(init_arg)

Returns a specification to start this module under a supervisor.

create_channel(pid)
get_connection(pid)
init(config)

Traps exits so all the linked connection and multiplexed channels can be restarted by this worker. Triggers an async connection but making sure future calls need to wait for the connection to happen before them.

start_link(config)

Link to this section Functions

Link to this function

checkin_channel(pid, channel) View Source 
checkin_channel(pid(), AMQP.Channel.t()) :: :ok

Link to this function

checkout_channel(pid) View Source 
checkout_channel(pid()) ::
  {:ok, AMQP.Channel.t()} | {:error, :disconnected} | {:error, :out_of_channels}

Link to this function

child_spec(init_arg) View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function

create_channel(pid) View Source 
create_channel(pid()) :: {:ok, AMQP.Channel.t()} | {:error, any()}

Link to this function

get_connection(pid) View Source 
get_connection(pid()) :: {:ok, AMQP.Connection.t()} | {:error, :disconnected}

Link to this function

init(config) View Source

Traps exits so all the linked connection and multiplexed channels can be restarted by this worker. Triggers an async connection but making sure future calls need to wait for the connection to happen before them.

  • config is the rabbitmq config settings
Link to this function

start_link(config) View Source 
start_link(ExRabbitPool.Worker.RabbitConnection.State.config()) ::
  GenServer.on_start()