Packages

rabbit_mq

0.0.0-alpha-0
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.10 0.0.9 0.0.8 0.0.7 0.0.2 0.0.1 0.0.0-alpha-9 0.0.0-alpha-8 0.0.0-alpha-7 0.0.0-alpha-6 0.0.0-alpha-5 0.0.0-alpha-4 0.0.0-alpha-3 0.0.0-alpha-2 0.0.0-alpha-12 0.0.0-alpha-11 0.0.0-alpha-10 0.0.0-alpha-1 0.0.0-alpha-0

🐇 The RabbitMQ client that helps you build consistent and well-balanced Producer/Consumer pipelines

HexDocs

Current section

Files

Jump to
Readme
27 Versions
6 Dependencies
0 Dependants
Files
Activity
rabbit_mq lib mq topology queue.ex
Raw

lib/mq/topology/queue.ex 

defmodule MQ.Topology.Queue do

  alias AMQP.{

    Channel,

    Queue

  }



  alias MQ.Topology.Config



  @spec purge_all(Channel.t()) :: {:ok, list()}

  def purge_all(channel) do

    queues = Config.gen() |> get_queues()

    results = purge_all(channel, queues)



    {:ok, results}

  end



  defp purge_all(channel, queues) do

    queues |> Enum.map(&Queue.purge(channel, &1))

  end



  defp get_queues(topology) do

    topology

    |> Stream.flat_map(& &1.queues)

    |> Stream.flat_map(fn {dlq, queue} -> [dlq, queue] end)

    |> Stream.map(& &1.name)

    |> Stream.reject(&(&1 == ""))

    |> Enum.uniq()

  end

end