TaskBunny

v0.3.4

TaskBunny v0.3.4 TaskBunny.Worker View Source

A GenServer that listens a queue and consumes messages.

You don’t have to call or start worker explicity. TaskBunny loads config and starts workers automatically for you.

Link to this section Summary

Types

t()

Struct that represents a state of the worker GenServer

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor

stop_consumer(pid)

Stops consuming messages from queue. Note this doesn’t terminate the process and the jobs currently running will continue so

Link to this section Types

Link to this type t() View Source 
t() :: %TaskBunny.Worker{
  channel: AMQP.Channel.t() | nil,
  concurrency: integer(),
  consumer_tag: String.t() | nil,
  host: atom(),
  job_stats: %{failed: integer(), succeeded: integer(), rejected: integer()},
  queue: String.t(),
  runners: integer()
}

Struct that represents a state of the worker GenServer.

Link to this section Functions

Link to this function child_spec(arg) View Source

Returns a specification to start this module under a supervisor.

See Supervisor.

Link to this function stop_consumer(pid) View Source 
stop_consumer(pid()) :: :ok

Stops consuming messages from queue. Note this doesn’t terminate the process and the jobs currently running will continue so.