Packages

rabbit

0.5.1
0.21.0 0.20.0 0.19.0 0.18.0 0.17.0 0.16.1 0.16.0 0.15.0 0.14.0 0.13.0 0.12.0 0.11.0 0.10.0 0.9.0 0.8.1 0.8.0 0.7.1 0.7.0 0.6.3 0.6.2 0.6.1 0.6.0 0.5.1 0.5.0 0.4.0 0.3.0 0.2.2 0.2.1 0.2.0 0.1.0

A set of tools for building robust applications with RabbitMQ.

HexDocs

Current section

Files

Jump to
Readme
30 Versions
4 Dependencies
Dependants
Files
Activity
rabbit lib rabbit worker.ex
Raw

lib/rabbit/worker.ex 

defmodule Rabbit.Worker do

  @moduledoc false



  use DynamicSupervisor



  ################################

  # Public API

  ################################



  @doc false

  def child_spec(args) do

    %{

      id: __MODULE__,

      start: {__MODULE__, :start_link, args}

    }

  end



  @doc false

  def start_link(opts \\ []) do

    DynamicSupervisor.start_link(__MODULE__, [], opts)

  end



  @doc false

  def start_child(message, opts \\ []) do

    pool_total = pool_total()

    worker = message |> :erlang.phash2(pool_total) |> get_name()

    child = {Rabbit.Worker.Executer, [message, opts]}

    DynamicSupervisor.start_child(worker, child)

  end



  @doc false

  def get_name(number) do

    Module.concat(Rabbit.Worker, ".#{number}")

  end



  @spec pool_total :: number()

  def pool_total do

    {:ok, pool_size} = Rabbit.Config.get(:worker_pool_size)

    pool_size - 1

  end



  ################################

  # DynamicSupervisor Callbacks

  ################################



  @doc false

  @impl DynamicSupervisor

  def init(_arg) do

    DynamicSupervisor.init(strategy: :one_for_one)

  end

end