bugfix: don't register the subscriber twice (#85)

entitydb-io · Sep 7, 2022 · 952ef0e · 952ef0e
1 parent 066b2d2
commit 952ef0e
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/src/EntityDb.Common/Extensions/ServiceCollectionExtensions.cs b/src/EntityDb.Common/Extensions/ServiceCollectionExtensions.cs
@@ -38,8 +38,6 @@ private static void AddBufferBlockTransactionProcessorQueue<TTransactionProcesso
 
         serviceCollection.AddHostedService(serviceProvider =>
           serviceProvider.GetRequiredService<BufferBlockTransactionQueue<TTransactionProcessor>>());
-
-        serviceCollection.AddSingleton<ITransactionSubscriber, TransactionProcessorSubscriber<TTransactionProcessor>>();
     }
 
     internal static void Add<TService>(this IServiceCollection serviceCollection, ServiceLifetime serviceLifetime,
@@ -80,10 +78,7 @@ public static void AddTransactionProcessorSubscriber<TTransactionProcessor>(this
 
         serviceCollection.AddSingleton<TransactionProcessorSubscriber<TTransactionProcessor>>();
 
-        serviceCollection.AddSingleton<ITransactionSubscriber>(
-            serviceProvider =>
-                serviceProvider.GetRequiredService<TransactionProcessorSubscriber<TTransactionProcessor>>()
-        );
+        serviceCollection.AddSingleton<ITransactionSubscriber, TransactionProcessorSubscriber<TTransactionProcessor>>();
 
         if (testMode)
         {