phatboyg

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

namespace ChannelUsage
{
    class Program
    {
        static IBusControl _serverBus;

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

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

        app.UseMvc();

phatboyg

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

namespace StateMachineTest
{
    class Program

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

04c71ebe6e1049cc747f00476a93aef99337d2213b84eff6f0daa8d97fe81bd01b24a80919f8e1fc376ea78f4db6437e361272c52b3f3e8b72b14a575734447fe1

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

namespace SagaLockupRepro
{
    using System;
    using System.Threading;
    using Automatonymous;
    using MassTransit;
    using MassTransit.NLogIntegration;
    using MassTransit.RabbitMqTransport;
    using MassTransit.Saga;

phatboyg

08:43:24,973 INFO  Configuration Result:
[Success] Name MassTransitStressConsole
[Success] DisplayName MassTransit RabbitMQ Stress Console
[Success] Description Generates a stressful load on RabbitMQ using MassTransit
[Success] ServiceName MassTransitStressConsole
08:43:25,005 INFO  Topshelf v3.2.150.0, .NET Framework v4.0.30319.34209
08:43:25,036 INFO  RabbitMQ Stress Test (using MassTransit)
08:43:25,036 INFO  Host: rabbitmq://localhost/stress_service?prefetch=20
08:43:25,051 INFO  Username: guest
08:43:25,051 INFO  Password: *****

phatboyg

# Setting up path...
source dnvm.sh

export PATH="/usr/local/bin:/usr/bin:/bin:/usr/local/sbin:/usr/sbin:/sbin:/usr/local/git/bin:/usr/X11/bin:~/bin:"
[[ -s "$HOME/.rvm/scripts/rvm" ]] && source "$HOME/.rvm/scripts/rvm" # This loads RVM into a shell session.

if [ -f /usr/local/etc/bash_completion.d/git-completion.bash ]; then
  . /usr/local/etc/bash_completion.d/git-completion.bash;
fi