RabbitMQ

This tutorial will get you from zero to up and running with RabbitMQ and MassTransit.

• The source for this sample is available on GitHub (opens new window).

Prerequisites

NOTE

The following instructions assume you are starting from a completed In-Memory Quick Start

This example requires the following:

• a functioning installation of the dotnet runtime and sdk (at least 6.0)
• a functioning installation of docker with docker compose support

Get RabbitMQ up and running

For this quick start we recommend running the preconfigured Docker image maintained by the MassTransit team (opens new window). It includes the delayed exchange plug-in, as well as the Management interface enabled.

$ docker run -p 15672:15672 -p 5672:5672 masstransit/rabbitmq

If you are running on an ARM platform

$ docker run --platform linux/arm64 -p 15672:15672 -p 5672:5672 masstransit/rabbitmq

Once its up and running you can log into (opens new window) the broker using guest, guest. You can see message rates, routings and active consumers using this interface.

Change the Transport to RabbitMQ

Add the MassTransit.RabbitMQ package to the project.

$ dotnet add package MassTransit.RabbitMQ

Edit Program.cs

Change UsingInMemory to UsingRabbitMq

public static IHostBuilder CreateHostBuilder(string[] args) =>
    Host.CreateDefaultBuilder(args)
        .ConfigureServices((hostContext, services) =>
        {
            services.AddMassTransit(x =>
            {
                // elided...

                x.UsingRabbitMq((context,cfg) =>
                {
                    cfg.Host("localhost", "/", h => {
                        h.Username("guest");
                        h.Password("guest");
                    });

                    cfg.ConfigureEndpoints(context);
                });
            });

            services.AddHostedService<Worker>();
        });

localhost is where the docker image is running. We are inferring the default port of 5672 and are using \ as the virtual host (opens new window). guest and guest are the default username and password to talk to the cluster and management dashboard (opens new window).

Run the project

$ dotnet run

The output should have changed to show the message consumer generating the output (again, press Control+C to exit). Notice that the bus address now starts with rabbitmq.

Building...
info: MassTransit[0]
      Configured endpoint Message, Consumer: GettingStarted.MessageConsumer
info: Microsoft.Hosting.Lifetime[0]
      Application started. Press Ctrl+C to shut down.
info: Microsoft.Hosting.Lifetime[0]
      Hosting environment: Development
info: Microsoft.Hosting.Lifetime[0]
      Content root path: /Users/chris/Garbage/start/GettingStarted
info: MassTransit[0]
      Bus started: rabbitmq://localhost/
info: GettingStarted.MessageConsumer[0]
      Received Text: The time is 3/24/2021 12:11:10 PM -05:00

At this point the service is connecting to RabbbitMQ on localhost and publishing messages which are received by the consumer.

🎉