Packages

yggdrasil

1.2.2
6.0.3 6.0.2 6.0.1 6.0.0 5.0.2 5.0.1 5.0.0 4.1.6 4.1.5 4.1.4 4.1.3 4.1.2 4.1.1 4.1.0 4.0.0 3.3.4 3.3.3 3.3.2 3.3.1 3.3.0 3.2.3 3.2.2 3.2.1 3.2.0 3.1.0 3.0.3 3.0.2 3.0.1 3.0.0 2.1.0 2.0.8 2.0.7 2.0.6 2.0.5 2.0.4 2.0.3 2.0.2 2.0.1 2.0.0 1.2.3 1.2.2 1.2.1 1.1.1 1.1.0 1.0.0

Agnostic pub/sub with Redis, RabbitMQ and Postgres support

HexDocs

Current section

Files

Jump to
Readme
45 Versions
3 Dependencies
Dependants
Files
Activity
yggdrasil lib yggdrasil broker rabbitmq_config.ex
Raw

lib/yggdrasil/broker/rabbitmq_config.ex 

defmodule Yggdrasil.Broker.RabbitMQConfig do

  defmodule Config do

    defstruct host: nil,

              port: nil,

              username: nil,

              password: nil,

              virtual_host: nil

  end



  def settings, do: [:host, :port, :username, :password, :virtual_host]



  def fetch_env do

    app_config = settings

      |> Enum.reduce(%{}, fn (key, config) -> load_config_key(config, key) end)

    struct(Config, app_config)

  end



  def load_config_key(config, key) do

    case Application.get_env(:amqp, key) do

      :nil -> config

      value -> Dict.put(config, key, value)

    end

  end

end