Shuttle.Esb

A highly extensible service bus implementation.

Description

A highly configurable free open-source enterprise service bus that provides you with a mechanism to create Autonomous Business Components that are loosely coupled. This enables you to develop and deploy specific business functionality that can be independently versioned.

Programming language: C#

License: BSD 3-clause "New" or "Revised" License

Tags: RabbitMQ     Messaging     PubSub     Queue     Bus     Msmq    

Latest version: v11.0.1

README

Shuttle.Esb

A highly flexible and free .NET open-source enterprise service bus.

Documentation

There is extensive documentation on our site and you can make use of the samples to get you going.

Overview

Start a new Console Application project and select a Shuttle.Esb queue implementation from the [supported queues]({{ site.baseurl }}/packages/#queues):

Install-Package Shuttle.Esb.Msmq

Now we'll need select one of the supported containers:

Install-Package Shuttle.Core.Autofac

We'll also need to host our endpoint using the service host:

Install-Package Shuttle.Core.ServiceHost

Next we'll implement our endpoint in order to start listening on our queue:

internal class Program
{
    private static void Main()
    {
        ServiceHost.Run<Host>();
    }
}

public class Host : IServiceHost
{
    private IServiceBus _bus;

    public void Start()
    {
        var containerBuilder = new ContainerBuilder();
        var registry = new AutofacComponentRegistry(containerBuilder);

        ServiceBus.Register(registry);

        var resolver = new AutofacComponentResolver(containerBuilder.Build());

        _bus = ServiceBus.Create(resolver).Start();
    }

    public void Stop()
    {
        _bus.Dispose();
    }
}

A bit of configuration is going to be needed to help things along:

<configuration>
    <configSections>
        <section name="serviceBus" type="Shuttle.Esb.ServiceBusSection, Shuttle.Esb"/>
    </configSections>

    <serviceBus>
        <inbox 
            workQueueUri="msmq://./shuttle-server-work" 
            deferredQueueUri="msmq://./shuttle-server-deferred" 
            errorQueueUri="msmq://./shuttle-error" />
    </serviceBus>
</configuration>

Send a command message for processing

using (var bus = ServiceBus.Create(resolver).Start())
{
    bus.Send(new RegisterMemberCommand
    {
        UserName = "Mr Resistor",
        EMailAddress = "[email protected]"
    });
}

Publish an event message when something interesting happens

using (var bus = ServiceBus.Create(resolver).Start())
{
    bus.Publish(new MemberRegisteredEvent
    {
        UserName = "Mr Resistor"
    });
}

Subscribe to those interesting events

resolver.Resolve<ISubscriptionManager>().Subscribe<MemberRegisteredEvent>();

Handle any messages

public class RegisterMemberHandler : IMessageHandler<RegisterMemberCommand>
{
    public void ProcessMessage(IHandlerContext<RegisterMemberCommand> context)
    {
        Console.WriteLine();
        Console.WriteLine("[MEMBER REGISTERED] : user name = '{0}'", context.Message.UserName);
        Console.WriteLine();

        context.Publish(new MemberRegisteredEvent
        {
            UserName = context.Message.UserName
        });
    }
}

public class MemberRegisteredHandler : IMessageHandler<MemberRegisteredEvent>
{
    public void ProcessMessage(IHandlerContext<MemberRegisteredEvent> context)
    {
        Console.WriteLine();
        Console.WriteLine("[EVENT RECEIVED] : user name = '{0}'", context.Message.UserName);
        Console.WriteLine();
    }
}