Skip to content

Instantly share code, notes, and snippets.

Chris Patterson phatboyg

Block or report user

Report or block phatboyg

Hide content and notifications from this user.

Learn more about blocking users

Contact Support about this user’s behavior.

Learn more about reporting abuse

Report abuse
View GitHub Profile
phatboyg / ConsoleApp2.csproj
Created Feb 10, 2019
Sample showing Azure Service Bus with Lock Timeout
View ConsoleApp2.csproj
<Project Sdk="Microsoft.NET.Sdk">
<PackageReference Include="MassTransit" Version="5.3.1" />
<PackageReference Include="MassTransit.Azure.ServiceBus.Core" Version="5.3.1" />
View Startup.cs
public class Startup
public void Configure(IApplicationBuilder app, IHostingEnvironment env)
if (env.IsDevelopment())
phatboyg / Program.cs
Last active Jan 28, 2019
Showing that exception works
View Program.cs
using System;
using System.ComponentModel.DataAnnotations;
using System.Threading.Tasks;
using Automatonymous;
using MassTransit;
using MassTransit.Saga;
namespace StateMachineTest
class Program
phatboyg /
Last active Feb 11, 2019
MassTransit 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.


View genesis_public_key
phatboyg /
Last active Apr 4, 2018
MassTransit 3 RabbitMQ Message Throughput

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.

View SagaRepro.cs
namespace SagaLockupRepro
using System;
using System.Threading;
using Automatonymous;
using MassTransit;
using MassTransit.NLogIntegration;
using MassTransit.RabbitMqTransport;
using MassTransit.Saga;
phatboyg / output.text
Created Jun 18, 2015
Performance Testing Handler Count with MT 2.10
View output.text
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: *****
View .profile
# Setting up path...
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;
phatboyg / Test.cs
Created May 8, 2015
Failing Test that hangs somewhere in the TPL/blocked... UGH!!
View Test.cs
namespace MassTransit.RabbitMqTransport.Tests
using System;
using System.Threading.Tasks;
using Configuration;
using NUnit.Framework;
using TestFramework.Messages;
You can’t perform that action at this time.