Packages

lapin

0.3.3
2.0.0 1.0.7 1.0.6 1.0.5 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 0.4.0 0.3.5 0.3.4 0.3.3 0.3.2 0.3.1 0.3.0 0.2.1 0.2.0 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Elixir RabbitMQ Client

HexDocs

Current section

Files

Jump to
Readme
24 Versions
2 Dependencies
Dependants
Files
Activity
lapin lib lapin pattern worker_queue.ex
Raw

lib/lapin/pattern/worker_queue.ex 

defmodule Lapin.Pattern.WorkQueue do

  @moduledoc """

  Lapin.Pattern implementation for the

  [Work Queues](http://www.rabbitmq.com/tutorials/tutorial-two-elixir.html)

  RabbitMQ pattern.

  """

  use Lapin.Pattern



  def consumer_ack(%Channel{config: config}), do: Keyword.get(config, :consumer_ack, true)

  def consumer_prefetch(%Channel{config: config}), do: Keyword.get(config, :consumer_prefetch, 1)



  def publisher_confirm(%Channel{config: config}),

    do: Keyword.get(config, :publisher_confirm, true)



  def publisher_mandatory(%Channel{config: config}),

    do: Keyword.get(config, :publisher_mandatory, true)



  def publisher_persistent(%Channel{config: config}),

    do: Keyword.get(config, :publisher_persistent, true)



  def routing_key(%Channel{config: config, routing_key: routing_key}),

    do: Keyword.get(config, :routing_key, routing_key)

end