TaskBunny

v0.3.4

TaskBunny v0.3.4 TaskBunny.PublisherWorker View Source

GenServer worker to publish a message on a queue

Link to this section Summary

Functions

child_spec(arg)

Returns a specification to start this module under a supervisor

handle_call(msg, from, state)

Attempt to get a channel for the current connection and publish the message on the specified queue

init(_)

Initializes the GenServer

start_link(_)

Starts the publisher

terminate(arg1, state)

Closes the AMQP channels opened to publish

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 handle_call(msg, from, state) View Source 
handle_call(
  {:publish, atom(), String.t(), String.t(), String.t(), list()},
  any(),
  map()
) :: {:reply, :ok, map()}

Attempt to get a channel for the current connection and publish the message on the specified queue

Link to this function init(_) View Source 
init(any()) :: {:ok, map()}

Initializes the GenServer

Link to this function start_link(_) View Source 
start_link(list()) :: GenServer.on_start()

Starts the publisher

Link to this function terminate(arg1, state) View Source 
terminate(any(), map()) :: :ok

Closes the AMQP channels opened to publish