Add support for MassTransit

samples/MassTransit/RabbitMQ/PureSender/Program.cs

@@ -0,0 +1,58 @@
+using System;
+using System.Threading.Tasks;
+using MassTransit;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Nybus;
+using Nybus.Configuration;
+using Nybus.MassTransit;
+using Types;
+
+namespace PureSender
+{
+    class Program
+    {
+        static async Task Main(string[] args)
+        {
+            var services = new ServiceCollection();
+
+            services.AddLogging(logging => logging.AddConsole().SetMinimumLevel(LogLevel.Trace));
+
+            services.AddNybus(nybus =>
+            {
+                nybus.UseMassTransitWithRabbitMq(c =>
+                {
+                    c.ConfigureMassTransit(mt =>
+                    {
+                        mt.Host(new Uri("rabbitmq://localhost"), h =>
+                        {
+                            h.Username("guest");
+                            h.Password("guest");
+                        });
+                    });
+                });
+
+                nybus.SubscribeToEvent<SomethingDoneEvent>(async (dispatcher, context) =>
+                {
+                    await Console.Out.WriteLineAsync($"Something was done: {context.Event.WhatWasDone}");
+                });
+            });
+
+            var serviceProvider = services.BuildServiceProvider();
+
+            var host = serviceProvider.GetRequiredService<IBusHost>();
+
+            await host.StartAsync();
+
+            await host.Bus.InvokeCommandAsync(new DoSomethingCommand
+            {
+                WhatToDo = "Whatever you want"
+            });
+
+            Console.WriteLine("Press ENTER to exit...");
+            Console.ReadLine();
+
+            await host.StopAsync();
+        }
+    }
+}

samples/MassTransit/RabbitMQ/PureSender/PureSender.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <ItemGroup>
+    <ProjectReference Include="..\Types\Types.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Nybus\Nybus.csproj" />
+    <ProjectReference Include="..\..\..\..\src\engines\Nybus.Engine.MassTransit.RabbitMq\Nybus.Engine.MassTransit.RabbitMq.csproj" />
+  </ItemGroup>
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp2.2</TargetFramework>
+    <LangVersion>latest</LangVersion>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="2.2.0" />
+  </ItemGroup>
+
+</Project>

samples/MassTransit/RabbitMQ/Receiver/Program.cs

@@ -0,0 +1,56 @@
+using System;
+using System.Threading.Tasks;
+using MassTransit;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Nybus;
+using Types;
+
+namespace Receiver
+{
+    class Program
+    {
+        static async Task Main(string[] args)
+        {
+            var services = new ServiceCollection();
+
+            services.AddLogging(logging => logging.AddConsole().SetMinimumLevel(LogLevel.Trace));
+
+            services.AddNybus(nybus =>
+            {
+                nybus.UseMassTransitWithRabbitMq(c =>
+                {
+                    c.ConfigureMassTransit(mt =>
+                    {
+                        mt.Host(new Uri("rabbitmq://localhost"), h =>
+                        {
+                            h.Username("guest");
+                            h.Password("guest");
+                        });
+                    });
+                });
+
+                nybus.SubscribeToCommand<DoSomethingCommand>(async (dispatcher, context) =>
+                {
+                    await Console.Out.WriteLineAsync($"Doing something: {context.Command.WhatToDo}");
+
+                    await dispatcher.RaiseEventAsync<SomethingDoneEvent>(new SomethingDoneEvent
+                    {
+                        WhatWasDone = context.Command.WhatToDo
+                    });
+                });
+            });
+
+            var serviceProvider = services.BuildServiceProvider();
+
+            var host = serviceProvider.GetRequiredService<IBusHost>();
+
+            await host.StartAsync();
+
+            Console.WriteLine("Press ENTER to exit...");
+            Console.ReadLine();
+
+            await host.StopAsync();
+        }
+    }
+}

samples/MassTransit/RabbitMQ/Receiver/Receiver.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <ItemGroup>
+    <ProjectReference Include="..\Types\Types.csproj" />
+    <ProjectReference Include="..\..\..\..\src\Nybus\Nybus.csproj" />
+    <ProjectReference Include="..\..\..\..\src\engines\Nybus.Engine.MassTransit.RabbitMq\Nybus.Engine.MassTransit.RabbitMq.csproj" />
+  </ItemGroup>
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>netcoreapp2.2</TargetFramework>
+    <LangVersion>latest</LangVersion>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="2.2.0" />
+  </ItemGroup>
+
+</Project>

samples/MassTransit/RabbitMQ/Types/Types.cs

@@ -0,0 +1,15 @@
+using System;
+using Nybus;
+
+namespace Types
+{
+    public class DoSomethingCommand : ICommand
+    {
+        public string WhatToDo { get; set; }
+    }
+
+    public class SomethingDoneEvent : IEvent
+    {
+        public string WhatWasDone { get; set; }
+    }
+}

samples/MassTransit/RabbitMQ/Types/Types.csproj

@@ -0,0 +1,11 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <ItemGroup>
+    <ProjectReference Include="..\..\..\..\src\Nybus.Abstractions\Nybus.Abstractions.csproj" />
+  </ItemGroup>
+
+  <PropertyGroup>
+    <TargetFramework>netstandard2.0</TargetFramework>
+  </PropertyGroup>
+
+</Project>

src/engines/Nybus.Engine.MassTransit.RabbitMq/Configuration/IMassTransitRabbitMqConfigurator.cs

@@ -0,0 +1,52 @@
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using MassTransit.RabbitMqTransport;
+using Microsoft.Extensions.DependencyInjection;
+using Nybus.MassTransit.RabbitMq;
+
+namespace Nybus.Configuration
+{
+    public interface IMassTransitRabbitMqConfigurator
+    {
+        void ConfigureMassTransit(Action<IRabbitMqBusFactoryConfigurator> configureMassTransit);
+
+        //void UseConfiguration(string sectionName = "MassTransit");
+
+
+    }
+
+    public class MassTransitRabbitMqConfigurator : IMassTransitRabbitMqConfigurator
+    {
+        private readonly IList<Action<IRabbitMqBusFactoryConfigurator>> _configurationActions = new List<Action<IRabbitMqBusFactoryConfigurator>>();
+
+        public void ConfigureMassTransit(Action<IRabbitMqBusFactoryConfigurator> configureMassTransit)
+        {
+            if (configureMassTransit == null)
+            {
+                throw new ArgumentNullException(nameof(configureMassTransit));
+            }
+
+            _configurationActions.Add(configureMassTransit);
+        }
+
+        private string _configurationSectionName;
+
+        public void UseConfiguration(string sectionName = "MassTransit")
+        {
+            _configurationSectionName = sectionName ?? throw new ArgumentNullException(nameof(sectionName));
+        }
+
+        public void Apply(INybusConfigurator nybus)
+        {
+            var busBuilder = new MassTransitRabbitMqBusBuilder();
+
+            foreach (var action in _configurationActions)
+            {
+                busBuilder.AddConfiguration(action);
+            }
+
+            nybus.AddServiceConfiguration(svc => svc.AddSingleton<IMassTransitRabbitMqBusBuilder>(busBuilder));
+        }
+    }
+}