A RabbitMQ broker process.

The broker is a Supervisor that encapsulates all the smaller pieces available in Rabbit into a single entity. It provides the following:

• Durable connection pooling through Rabbit.Connection.
• Automatic broker configuration through Rabbit.Topology.
• Simple message publishing through Rabbit.Producer.
• Simple message consumption through Rabbit.ConsumerSupervisor.

It's recommended that the documentation for each of these components is read when utilizing the broker process.

Be aware that the connection for each component of the broker is automatically configured to use the connection process created by the broker. You dont need to configure this yourself.

Example

defmodule MyBroker do
  use Rabbit.Broker

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

  # Callbacks

  @impl Rabbit.Broker
  def init(_type, opts) do
    # Perform any configuration
    # You can implement the callback for each component of the broker based
    # on the first arg.
    {:ok, opts}
  end

  @impl Rabbit.Broker
  def handle_message(message) do
    # Handle consumed messages
    {:ack, message}
  end

  @impl Rabbit.Broker
  def handle_error(message) do
    # Handle errors that occur within handle_message/1
    {:nack, message}
  end
end

# Start the broker
MyBroker.start_link(
  connection: [uri: "amqp://guest:guest@127.0.0.1:5672"],
  topology: [
    queues: [[name: "foo"], [name: "bar"]]
  ],
  producer: [pool_size: 10],
  consumers: [[queue: "foo"], [queue: "bar", prefetch_count: 10]]
)