MassTransit StructureMap Extensions

MassTransitStructureMapExtensions.cs

namespace MyApp.MassTransitExtensions
{
    using MassTransit;

    using StructureMap;
    using StructureMap.Graph;

    public static class MassTransitStructureMapExtensions
    {
        public static void ScanConsumers(this IContainer container)
        {
            container.Configure(
                x =>
                    {
                        x.Scan(
                            s =>
                                {
                                    s.TheCallingAssembly();
                                    s.AddAllTypesOf<IConsumer>();
                                });
                    });
        }

        public static void InjectBus(this IContainer container)
        {
            var bus = ServiceBusFactory.New(
                sbc =>
                    {
                        sbc.UseRabbitMq();
                        sbc.ReceiveFrom("rabbitmq://localhost/myqueue");
                        sbc.UseJsonSerializer();

                        sbc.Subscribe(s => s.LoadFrom(container));
                    });

            container.Configure(
                c =>
                    {
                        c.For<IServiceBus>().Singleton().Use(x => bus);
                    });
        }
    }
}