Current section
Files
Jump to
Current section
Files
lib/mq/__support/exclusive_queue.ex
defmodule MQ.Support.ExclusiveQueue do
@moduledoc """
Use to create exclusive queues in tests.
"""
alias AMQP.{Basic, Queue}
alias MQ.ConnectionManager
@this_module __MODULE__
@spec declare(list()) :: {:ok, String.t()} | Basic.error()
def declare(opts \\ []) when is_list(opts) do
{:ok, channel} = ConnectionManager.request_channel(@this_module)
queue = opts |> Keyword.get(:queue, "")
exchange = opts |> Keyword.fetch!(:exchange)
routing_key = opts |> Keyword.fetch!(:routing_key)
with {:ok, %{queue: queue}} <- channel |> assert_queue(queue),
:ok <- channel |> bind_queue(queue, exchange, routing_key),
do: {:ok, queue}
end
defp assert_queue(channel, queue) do
channel |> Queue.declare(queue, durable: false, exclusive: true)
end
defp bind_queue(channel, queue, exchange, routing_key) do
channel |> Queue.bind(queue, exchange, routing_key: routing_key)
end
end