Adding the basic work-able flow to demonstrate the event handling.

src/EdaSample.EventBus.Simple/PassThroughEventBus.cs

@@ -34,7 +34,6 @@ public void Subscribe()
 
         #region IDisposable Support
         private bool disposedValue = false; // To detect redundant calls
-
         void Dispose(bool disposing)
         {
             if (!disposedValue)
@@ -47,7 +46,6 @@ void Dispose(bool disposing)
                 disposedValue = true;
             }
         }
-
         public void Dispose() => Dispose(true);
         #endregion
     }

src/EdaSample.Services.Customer/Controllers/CustomersController.cs

@@ -0,0 +1,29 @@
+using EdaSample.Common.Events;
+using EdaSample.Services.Customer.Events;
+using Microsoft.AspNetCore.Mvc;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace EdaSample.Services.Customer.Controllers
+{
+    [Route("api/[controller]")]
+    public class CustomersController : Controller
+    {
+        private readonly IEventBus eventBus;
+
+        public CustomersController(IEventBus eventBus)
+        {
+            this.eventBus = eventBus;
+        }
+
+        [HttpPost]
+        public async Task<IActionResult> Create([FromBody] dynamic model)
+        {
+            var customerName = (string)model.Name;
+            await this.eventBus.PublishAsync(new CustomerCreatedEvent(customerName));
+            return Ok();
+        }
+    }
+}

src/EdaSample.Services.Customer/EdaSample.Services.Customer.csproj

@@ -4,6 +4,10 @@
     <TargetFramework>netcoreapp2.0</TargetFramework>
   </PropertyGroup>
 
+  <PropertyGroup Condition="'$(Configuration)|$(Platform)'=='Debug|AnyCPU'">
+    <LangVersion>latest</LangVersion>
+  </PropertyGroup>
+
   <ItemGroup>
     <Folder Include="wwwroot\" />
   </ItemGroup>
@@ -16,4 +20,9 @@
     <DotNetCliToolReference Include="Microsoft.VisualStudio.Web.CodeGeneration.Tools" Version="2.0.1" />
   </ItemGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\EdaSample.Common\EdaSample.Common.csproj" />
+    <ProjectReference Include="..\EdaSample.EventBus.Simple\EdaSample.EventBus.Simple.csproj" />
+  </ItemGroup>
+
 </Project>

src/EdaSample.Services.Customer/EventHandlers/CustomerCreatedEventHandler.cs

@@ -0,0 +1,24 @@
+using EdaSample.Common.Events;
+using EdaSample.Services.Customer.Events;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace EdaSample.Services.Customer.EventHandlers
+{
+    public class CustomerCreatedEventHandler : IEventHandler<CustomerCreatedEvent>
+    {
+        public bool CanHandle(IEvent @event)
+            => @event.GetType().Equals(typeof(CustomerCreatedEvent));
+
+        public Task<bool> HandleAsync(CustomerCreatedEvent @event, CancellationToken cancellationToken = default)
+        {
+            return Task.FromResult(true);
+        }
+
+        public Task<bool> HandleAsync(IEvent @event, CancellationToken cancellationToken = default)
+            => CanHandle(@event) ? HandleAsync((CustomerCreatedEvent)@event, cancellationToken) : Task.FromResult(false);
+    }
+}

src/EdaSample.Services.Customer/Events/CustomerCreatedEvent.cs

@@ -0,0 +1,24 @@
+using EdaSample.Common.Events;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace EdaSample.Services.Customer.Events
+{
+    public class CustomerCreatedEvent : IEvent
+    {
+        public CustomerCreatedEvent(string customerName)
+        {
+            this.Id = Guid.NewGuid();
+            this.Timestamp = DateTime.UtcNow;
+            this.CustomerName = customerName;
+        }
+
+        public Guid Id { get; }
+
+        public DateTime Timestamp { get; }
+
+        public string CustomerName { get; }
+    }
+}

src/EdaSample.Services.Customer/Startup.cs

@@ -2,6 +2,9 @@
 using System.Collections.Generic;
 using System.Linq;
 using System.Threading.Tasks;
+using EdaSample.Common.Events;
+using EdaSample.EventBus.Simple;
+using EdaSample.Services.Customer.EventHandlers;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Configuration;
@@ -24,11 +27,17 @@ public Startup(IConfiguration configuration)
         public void ConfigureServices(IServiceCollection services)
         {
             services.AddMvc();
+
+            services.AddTransient<IEventHandler, CustomerCreatedEventHandler>();
+            services.AddSingleton<IEventBus, PassThroughEventBus>();
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
         public void Configure(IApplicationBuilder app, IHostingEnvironment env)
         {
+            var eventBus = app.ApplicationServices.GetRequiredService<IEventBus>();
+            eventBus.Subscribe();
+
             if (env.IsDevelopment())
             {
                 app.UseDeveloperExceptionPage();

src/EdaSample.Services.Customer/appsettings.json

@@ -11,5 +11,8 @@
         "Default": "Warning"
       }
     }
+  },
+  "mssql": {
+    "connectionString": "Server=localhost\\sqlexpress;Database=EdaSample;User Id=eda;Password=eda;"
   }
 }