Updates to DI and examples.

RCommon-Team · Mar 9, 2024 · 2d515a7 · 2d515a7
1 parent 518eee6
commit 2d515a7
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/Examples/Examples.sln b/Examples/Examples.sln
@@ -111,8 +111,6 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Examples.EventHandling.Medi
 EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "CQRS", "CQRS", "{783F8A99-F164-42E3-BD7C-09D432D02DEE}"
 EndProject
-Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "CQRS", "CQRS", "{D724588A-9236-4175-A337-53C4530CC5A7}"
-EndProject
 Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Experimental", "Experimental", "{6509FEEC-F46C-4B03-82D4-8F2D78896160}"
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Examples.EventHandling.InMemoryEventBus", "EventHandling\Examples.EventHandling.InMemoryEventBus\Examples.EventHandling.InMemoryEventBus.csproj", "{86CE6DBE-418E-440B-9C27-58B00AFB2FCA}"

diff --git a/Src/RCommon.EventHandling/EventHandlingBuilderExtensions.cs b/Src/RCommon.EventHandling/EventHandlingBuilderExtensions.cs
@@ -27,6 +27,9 @@ public static IRCommonBuilder WithEventHandling<T>(this IRCommonBuilder builder,
             // Event Bus
             builder.Services.AddSingleton<IEventBus, InMemoryEventBus>();
 
+            // Event Routing
+            builder.Services.AddTransient<IEventRouter, EventRouter>();
+
             // Event Handling Configurations 
             var eventHandlingConfig = (T)Activator.CreateInstance(typeof(T), new object[] { builder });
             actions(eventHandlingConfig);

diff --git a/Src/RCommon.Persistence/PersistenceBuilderExtensions.cs b/Src/RCommon.Persistence/PersistenceBuilderExtensions.cs
@@ -1,10 +1,13 @@
 using Microsoft.Extensions.DependencyInjection;
 using RCommon.Entities;
+using RCommon.EventHandling;
+using RCommon.EventHandling.Producers;
 using RCommon.Persistence;
 using RCommon.Persistence.Transactions;
 using System;
 using System.Collections.Generic;
 using System.Linq;
+using System.Runtime.CompilerServices;
 using System.Text;
 using System.Threading.Tasks;
 
@@ -65,6 +68,7 @@ public static IRCommonBuilder WithPersistence<TObjectAccess, TUnitOfWork>(this I
         /// <returns>Updated instance of <see cref="IRCommonBuilder"/>RCommon Configuration</returns>
         private static IRCommonBuilder WithChangeTracking(this IRCommonBuilder config)
         {
+            config.Services.AddTransient<IEventRouter, EventRouter>();
             config.Services.AddScoped<IEventTracker, InMemoryEventTracker>();
             return config;
         }