Instantly share code, notes, and snippets.

Embed
What would you like to do?
public class PlayMassTransitModule : MassTransitModuleBase
{
public override void Load()
{
base.Load();
RegisterEndpointFactory(x =>
{
x.RegisterTransport<LoopbackEndpoint>();
x.RegisterTransport<MulticastUdpEndpoint>();
x.RegisterTransport<MsmqEndpoint>();
});
RegisterServiceBus(@"msmq://localhost/mt_mike_publisher", x =>
{
x.SetConcurrentConsumerLimit(1);
ConfigureSubscriptionClient(@"msmq://localhost/mt_subscriptions", x);
});
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment