Packages
step_flow
0.2.1
1.9.0-rc2
1.9.0-rc1
1.9.0-rc0
1.8.2
1.8.1
1.8.1-rc8
1.8.1-rc7
1.8.1-rc6
1.8.1-rc5
1.8.1-rc4
1.8.1-rc3
1.8.1-rc2
1.8.1-rc1
1.8.1-rc0
1.8.0
1.8.0-rc3
1.8.0-rc2
1.8.0-rc1
1.8.0-rc0
1.7.3
1.7.3-rc4
1.7.3-rc3
1.7.3-rc2
1.7.3-rc1
1.7.3-rc0
1.7.2
1.7.2-rc4
1.7.2-rc3
1.7.2-rc2
1.7.2-rc1
1.7.2-rc0
1.7.1
1.7.0
1.7.0-rc1
1.7.0-rc0
1.6.1
1.6.1-rc1
1.6.1-rc0
1.6.0
1.6.0-rc9
1.6.0-rc8
1.6.0-rc7
1.6.0-rc6
1.6.0-rc5
1.6.0-rc4
1.6.0-rc3
1.6.0-rc20
1.6.0-rc2
1.6.0-rc19
1.6.0-rc18
1.6.0-rc17
1.6.0-rc16
1.6.0-rc15
1.6.0-rc14
1.6.0-rc13
1.6.0-rc12
1.6.0-rc11
1.6.0-rc10
1.6.0-rc1
1.5.0
1.5.0-rc1
1.4.2-rc2
1.4.2-rc1
1.4.1
1.4.1-rc1
1.4.0
1.4.0-rc4
1.4.0-rc3
1.4.0-rc2
1.4.0-rc1
1.3.1
1.3.0
1.3.0-rc
1.2.0
1.1.0
1.0.0
1.0.0-rc9
1.0.0-rc8
1.0.0-rc7
1.0.0-rc6
1.0.0-rc5
1.0.0-rc1
0.2.13
0.2.12
0.2.11
0.2.10
0.2.9
0.2.8
0.2.7
0.2.6
0.2.5
0.2.4
0.2.3
0.2.2
0.2.1
0.2.0
0.1.8
0.1.7
0.1.6
0.1.5
0.1.4
0.1.3
0.1.2
0.1.1
0.1.0
0.0.24
0.0.23
0.0.22
0.0.21
0.0.20
0.0.19
0.0.18
0.0.17
0.0.16
0.0.15
0.0.14
0.0.13
0.0.12
0.0.11
0.0.10
0.0.9
0.0.8
0.0.7
0.0.6
0.0.4
0.0.3
0.0.2
0.0.1
Step flow manager for Elixir applications
Current section
Files
Jump to
Current section
Files
lib/step_flow/amqp/helpers.ex
defmodule StepFlow.Amqp.Helpers do
require Logger
@moduledoc """
Helpers for AMQP.
"""
@doc """
Get AMQP URL from the configuration or environment variables.
- `hostname` Setup the hostname of the RabbitMQ service
- `username` Setup the username of the RabbitMQ service
- `password` Setup the password of the RabbitMQ service
- `port` Setup the port of the RabbitMQ service
- `virtual_host` Setup the virtual host of the RabbitMQ service
Hardcoded example:
config :step_flow, StepFlow.Amqp,
hostname: "example.com",
port: "5678",
username: "mediacloudai",
password: "mediacloudai",
virtual_host: "media_cloud_ai_dev"
Environment getter example:
config :step_flow, StepFlow.Amqp,
hostname: {:system, "AMQP_HOSTNAME"},
port: {:system, "AMQP_PORT"},
username: {:system, "AMQP_USERNAME"},
password: {:system, "AMQP_PASSWORD"},
virtual_host: {:system, "AMQP_VIRTUAL_HOST"},
"""
def get_amqp_connection_url do
hostname = StepFlow.Configuration.get_var_value(StepFlow.Amqp, :hostname)
username = StepFlow.Configuration.get_var_value(StepFlow.Amqp, :username)
password = StepFlow.Configuration.get_var_value(StepFlow.Amqp, :password)
virtual_host = get_amqp_virtual_host()
port = get_amqp_port()
Logger.warn("#{__MODULE__}: Connecting with hostname: #{hostname}")
url =
"amqp://" <> username <> ":" <> password <> "@" <> hostname <> ":" <> port <> virtual_host
Logger.warn("#{__MODULE__}: Connecting with url: #{url}")
url
end
defp get_amqp_port do
StepFlow.Configuration.get_var_value(StepFlow.Amqp, :port, 5672)
|> StepFlow.Configuration.to_string()
end
defp get_amqp_virtual_host do
StepFlow.Configuration.get_var_value(StepFlow.Amqp, :virtual_host, "")
|> case do
"" -> ""
virtual_host -> "/" <> virtual_host
end
end
end