A RabbitMQ consumer supervisor process.

This allows starting and supervising multiple Rabbit.Consumer processes with ease. Rather than creating a module for each consumer and implementing repetitive logic - the same callbacks are used across all child consumers.

Example

# This is a connection
defmodule MyConnection do
  use Rabbit.Connection

  def start_link(opts \\ []) do
    Rabbit.Connection.start_link(__MODULE__, opts, name: __MODULE__)
  end

  # Callbacks

  @impl Rabbit.Connection
  def init(:connection, opts) do
    # Perform any runtime configuration
    {:ok, opts}
  end
end

# This is a consumer supervisor
defmodule MyConsumers do
  use Rabbit.ConsumerSupervisor

  def start_link(consumers \\ []) do
    Rabbit.ConsumerSupervisor.start_link(__MODULE__, consumers, name: __MODULE__)
  end

  # Callbacks

  @impl Rabbit.ConsumerSupervisor
  def init(:consumer_supervisor, _consumers) do
    # Perform any runtime configuration for the supervisor
    consumers = [
      [connection: MyConnection, queue: "my_queue1", prefetch_count: 5],
      [connection: MyConnection, queue: "my_queue2", prefetch_count: 10]
    ]

    {:ok, consumers}
  end

  def init(:consumer, opts) do
    # Perform any runtime configuration per consumer
    {:ok, opts}
  end

  @impl Rabbit.ConsumerSupervisor
  def handle_setup(channel, queue) do
    # Perform exchange or queue setup per consumer
    AMQP.Queue.declare(channel, queue)

    :ok
  end

  @impl Rabbit.ConsumerSupervisor
  def handle_message(message) do
    # Handle messages per consumer
    {:ack, message}
  end

  @impl Rabbit.ConsumerSupervisor
  def handle_error(message) do
    # Handle errors that occur per consumer
    {:nack, message}
  end
end

# Start the connection
MyConnection.start_link()

# Start the consumers
MyConsumers.start_link()