phatboyg

The message throughput of MassTransit using RabbitMQ, compared to the "one-way" RPC used in the test published at RestBus.

The send rate of MassTransit doing non-durable messages to RabbitMQ is 8,881 per second The consume rate of those same messages is 8,881 per second.

That's a sustained message throughput over 100,000 messages (5,000 per client thread, the same as the test linked above).

So, to be fair, there is no performance difference between the two in practice.

phatboyg

04c71ebe6e1049cc747f00476a93aef99337d2213b84eff6f0daa8d97fe81bd01b24a80919f8e1fc376ea78f4db6437e361272c52b3f3e8b72b14a575734447fe1

phatboyg

Conductor

Conductor is a layer on top of MassTransit for managing, controlling, and monitoring communication between services. Conductor provides a consistent set of capabilities for services and decouples the complexity of routing, failure handling, and monitoring from the service code itself. This allows service visibility and control without requiring services to be modified to apply behaviorial changes related to how those services interact.

Contents

• Architecture
• Features

phatboyg

using System;
using System.ComponentModel.DataAnnotations;
using System.Threading.Tasks;
using Automatonymous;
using MassTransit;
using MassTransit.Saga;

namespace StateMachineTest
{
    class Program

phatboyg

public class Startup
{
    public void Configure(IApplicationBuilder app, IHostingEnvironment env)
    {
        if (env.IsDevelopment())
        {
            app.UseDeveloperExceptionPage();
        }

        app.UseMvc();

phatboyg

<Project Sdk="Microsoft.NET.Sdk">

  <PropertyGroup>
    <OutputType>Exe</OutputType>
    <TargetFramework>netcoreapp2.2</TargetFramework>
  </PropertyGroup>

  <ItemGroup>
    <PackageReference Include="MassTransit" Version="5.3.1" />
    <PackageReference Include="MassTransit.Azure.ServiceBus.Core" Version="5.3.1" />

phatboyg

using System;
using System.Threading.Tasks;
using MassTransit;

namespace ChannelUsage
{
    class Program
    {
        static IBusControl _serverBus;