with_quorum_queue_type.md

Consumer with quorum queue type

You can change from classic to a quorum queue type by specifying corresponding queue arguments. Read more about quorum queues here.

Example

defmodule WithQuorumQueueType do
  @behaviour GenRMQ.Consumer

  def init() do
    [
      connection: "amqp://guest:guest@localhost:5672",
      queue: "example_queue",
      exchange: "example_exchange",
      routing_key: "routing_key.#",
      prefetch_count: "10",
      queue_options: [
        arguments: [
           {"x-queue-type", :longstr, "quorum"}
        ]
      ],
      deadletter_queue_options: [
        arguments: [
           {"x-queue-type", :longstr, "quorum"}
        ]
      ]
    ]
  end

  def handle_message(%GenRMQ.Message{} = message), do: GenRMQ.Consumer.ack(message)

  def handle_error(%GenRMQ.Message{} = message, _reason), do: GenRMQ.Consumer.reject(message, false)

  def consumer_tag(), do: "consumer-tag"

  def start_link(), do: GenRMQ.Consumer.start_link(__MODULE__, name: __MODULE__)
end

Outcome:

• durable example_exchange.deadletter exchange created or redeclared
• durable example_queue_error quorum queue created or redeclared and bound to example_exchange.deadletter exchange
• durable topic example_exchange exchange created or redeclared
• durable example_queue quorum queue created or redeclared and bound to example_exchange exchange
• queue example_queue has a deadletter exchange set to example_exchange.deadletter
• every handle_message callback will be executed in a separate supervised task. If the task fails handle_error/2 will be called
• on failed rabbitmq connection it will wait for a bit and then reconnect