Current section
Files
Jump to
Current section
Files
lib/conduit/broker/configure.ex
defmodule Conduit.Broker.Configure do
@moduledoc """
Provides macros to define the messaage queue topology.
Within your broker, you can configure the topology of
your message queue. Not every macro or options will apply
to all message queues.
## Examples
defmodule MyApp.Broker do
use Conduit.Broker, otp_app: :my_app
configure do
exchange "my.topic"
queue "my.queue", from: ["every.where"], exchange: "my.topic"
queue "your.queue", from: ["else.where"], exchange: "my.topic"
end
end
"""
@doc false
defmacro __using__(_opts) do
quote do
Module.register_attribute(__MODULE__, :topology, accumulate: :true)
import Conduit.Broker.Configure
@before_compile unquote(__MODULE__)
end
end
@doc """
Defines an exchange to setup.
"""
defmacro exchange(name, opts \\ []) do
quote do
@topology {:exchange, unquote(name), unquote(opts)}
end
end
@doc """
Defines a queue to setup.
"""
defmacro queue(name, opts \\ []) do
quote do
@topology {:queue, unquote(name), unquote(opts)}
end
end
@doc false
defmacro __before_compile__(_) do
quote do
@ordered_topology @topology |> Enum.reverse
def topology, do: @ordered_topology
end
end
end