BroadwayRabbitMQ

To use BroadwayRabbitMQ in your Elixir project, add :broadway_rabbitmq to your mix.exs dependencies list.

def deps do
  [
    {:broadway_rabbitmq, "~> 0.7.0"}
  ]
end

If you are contributing to the project or running integration tests locally, you need a running RabbitMQ instance on localhost:5672. You can use the provided docker-compose.yml to spin up RabbitMQ via Docker Compose.

docker-compose up -d

You can use the provided docker-compose.yml to spin up a RabbitMQ instance for local development or testing. This configuration uses the rabbitmq:3.11.9-alpine image and exposes the standard AMQP port 5672 to your host machine.

services:
  rabbitmq:
    image: "rabbitmq:3.11.9-alpine"
    ports:
      - "5672:5672"

To consume messages from RabbitMQ, configure a producer in your Broadway pipeline using BroadwayRabbitMQ.Producer. You must specify the queue name in the producer options. The concurrency option controls how many processes are started to consume from the queue.

defmodule MyBroadway do
  use Broadway

  def start_link(_opts) do
    Broadway.start_link(__MODULE__,
      name: __MODULE__,
      producer: [
        module: {BroadwayRabbitMQ.Producer,
          queue: "my_queue",
        },
        concurrency: 1
      ],
      processors: [
        default: [
          concurrency: 10
        ]
      ]
    )
  end

  def handle_message(_, message, _) do
    IO.inspect(message.data, label: "Got message")
    message
  end
end