RabbitMQ Consumer.

Configuration

• :connection - the connection module which implements RMQ.Connection behaviour. Defaults to RMQ.Connection;
• :queue - the name of the queue to consume. Will be created if does not exist;
• :exchange - the name of the exchange to which queue should be bound. Also accepts two-element tuple {type, name}. Defaults to "";
• :routing_key - queue binding key. Defaults to queue; Will be created if does not exist. Defaults to "";
• :dead_letter - defines if the consumer should setup deadletter exchange and queue. Defaults to true;
• :dead_letter_queue - the name of dead letter queue. Defaults to "#{queue}_error";
• :dead_letter_exchange - the name of the exchange to which dead_letter_queue should be bound. Also accepts two-element tuple {type, name}. Defaults to "#{exchange}.dead-letter";
• :dead_letter_routing_key - routing key for dead letter messages. Defaults to queue;
• :concurrency - defines if consume/3 callback should be called in a separate process. Defaults to true;
• :prefetch_count - sets the message prefetch count. Defaults to 10;
• :consumer_tag - consumer tag. Defaults to a current module name;
• :reconnect_interval - a reconnect interval in milliseconds. It can be also a function that accepts the current connection attempt as a number and returns a new interval. Defaults to 5000;

Examples

defmodule MyApp.Consumer do
  use RMQ.Consumer,
    queue: "my-app-consumer-queue",
    exchange: {:direct, "my-exchange"}

  @impl RMQ.Consumer
  def consume(chan, payload, meta) do
    # do something with the payload
    ack(chan, meta.delivery_tag)
  end
end

defmodule MyApp.Consumer2 do
  use RMQ.Consumer

  @impl RMQ.Consumer
  def config do
    [
      queue: System.fetch_env!("QUEUE_NAME"),
      reconnect_interval: fn attempt -> attempt * 1000 end,
    ]
  end

  @impl RMQ.Consumer
  def consume(chan, payload, meta) do
    # do something with the payload
    ack(chan, meta.delivery_tag)
  end
end