bugfix: don't register the subscriber twice

entitydb-io · Sep 7, 2022 · 7eaa56d · 7eaa56d
1 parent 25d0de8
commit 7eaa56d
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
@@ -39,8 +39,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,
@@ -74,10 +72,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)
         {