Packages

lapin

0.3.4
2.0.0 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.4.0 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Elixir RabbitMQ Client

HexDocs

Current section

Files

Jump to
Readme
24 Versions
2 Dependencies
Dependants
Files
Activity
lapin lib lapin connection supervisor.ex
Raw

lib/lapin/connection/supervisor.ex 

defmodule Lapin.Connection.Supervisor do

  @moduledoc """

  Lapin Connections Supervisor

  """

  use Supervisor

  require Logger



  @spec start_link(configuration :: Lapin.config()) :: Supervisor.on_start()

  def start_link(configuration) do

    Supervisor.start_link(__MODULE__, configuration, name: __MODULE__)

  end



  def init(configuration) do

    configuration

    |> Enum.map(fn connection ->

      module = Keyword.get(connection, :module)

      worker(Lapin.Connection, [connection, [name: module]], [id: module])

    end)

    |> supervise(strategy: :one_for_one)

  end

end