Packages

conduit

0.2.1
0.12.10 0.12.9 0.12.8 0.12.7 0.12.6 0.12.5 0.12.4 0.12.3 0.12.2 0.12.1 0.12.0 0.11.0 0.10.8 0.10.7 0.10.6 0.10.5 0.10.4 0.10.3 0.10.2 0.10.1 0.10.0 0.9.0 0.8.3 0.8.2 0.8.1 0.8.0 0.7.2 0.7.1 0.7.0 0.6.2 0.6.1 0.6.0 0.5.0 0.4.0 0.3.0 0.2.1 0.2.0 0.1.1 0.1.0

Message queue framework, with support for middleware and multiple adapters.

HexDocs

Current section

Files

Jump to
Readme
39 Versions
3 Dependencies
5 Dependants
Files
Activity
conduit lib conduit broker configure.ex
Raw

lib/conduit/broker/configure.ex 

defmodule Conduit.Broker.Configure do

  @moduledoc false



  @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