HaimKortovich
2a8f2ffc2d
All checks were successful
Build and Publish / build-release (push) Successful in 1m38s
22 lines
496 B
Elixir
22 lines
496 B
Elixir
defmodule PolicyService.MessageBus do
|
|
use AMQP
|
|
|
|
def publish(exchange, routing_key, event) do
|
|
payload = Jason.encode!(event)
|
|
|
|
:ok =
|
|
AMQP.Basic.publish(channel(), exchange, routing_key, payload,
|
|
content_type: "application/json",
|
|
persistent: true
|
|
)
|
|
end
|
|
|
|
defp channel do
|
|
{:ok, conn} = AMQP.Connection.open(amqp_url())
|
|
{:ok, chan} = AMQP.Channel.open(conn)
|
|
chan
|
|
end
|
|
|
|
defp amqp_url, do: Application.fetch_env!(:policy_service, :amqp_url)
|
|
end
|