diff --git a/src/EntityDb.Common/Extensions/ServiceCollectionExtensions.cs b/src/EntityDb.Common/Extensions/ServiceCollectionExtensions.cs
index 782d5b39..bb1bd0e3 100644
--- 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)
         {