Packages

task_bunny

0.0.1-dev.3
0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.2 0.2.1 0.2.0 0.1.2 0.1.1 0.1.0 0.1.0-rc.3 0.1.0-rc.2 0.1.0-rc.1 0.0.1-dev.10 0.0.1-dev.9 0.0.1-dev.8 0.0.1-dev.7 0.0.1-dev.6 0.0.1-dev.5 0.0.1-dev.4 0.0.1-dev.3 0.0.1-dev.2

Background processing application/library written in Elixir that uses RabbitMQ as a messaging backend

HexDocs

Current section

Files

Jump to
Readme
23 Versions
2 Dependencies
Dependants
Files
Activity
task_bunny lib mix tasks task_bunny.queue.reset.ex
Raw

lib/mix/tasks/task_bunny.queue.reset.ex 

defmodule Mix.Tasks.TaskBunny.Queue.Reset do

  use Mix.Task



  @shortdoc "Reset all queues in config files"



  @moduledoc """

  Mix task to reset all queues.



  Please be aware it delete queues and recreate them.

  So all existing messages in the queues will go away.

  """



  alias TaskBunny.{Connection, Config}



  @doc false

  def run(_args) do

    Config.disable_auto_start()

    Mix.Task.run "app.start"



    _connections = Enum.map Config.hosts(), fn (host) ->

      Connection.start_link(host)

    end



    Config.jobs

    |> Enum.each(fn (job) -> reset_queue(job) end)

  end



  defp reset_queue(job_info) do

    Mix.shell.info "Resetting queues for #{inspect job_info}"



    conn = Connection.get_connection()

    job = job_info[:job]

    job.delete_queue(conn)

    job.declare_queue(conn)

  end

end