diff --git a/src/common/Elsa.Mediator/Extensions/DependencyInjectionExtensions.cs b/src/common/Elsa.Mediator/Extensions/DependencyInjectionExtensions.cs
index bfff39946..2ac94c073 100644
--- a/src/common/Elsa.Mediator/Extensions/DependencyInjectionExtensions.cs
+++ b/src/common/Elsa.Mediator/Extensions/DependencyInjectionExtensions.cs
@@ -14,7 +14,6 @@ using Elsa.Mediator.Options;
 using Elsa.Mediator.Services;
 using JetBrains.Annotations;
 using Microsoft.Extensions.Logging;
-using Microsoft.Extensions.Options;
 
 // ReSharper disable once CheckNamespace
 namespace Microsoft.Extensions.DependencyInjection;
@@ -55,27 +54,9 @@ public static class DependencyInjectionExtensions
             .AddSingleton<ICommandsChannel, CommandsChannel>()
             .AddSingleton<IJobsChannel, JobsChannel>()
             .AddSingleton<IJobQueue, JobQueue>()
-            .AddHostedService(sp =>
-            {
-                using var scope = sp.CreateScope();
-
-                var options = scope.ServiceProvider.GetRequiredService<IOptions<MediatorOptions>>().Value;
-                return ActivatorUtilities.CreateInstance<JobRunnerHostedService>(scope.ServiceProvider, options.JobWorkerCount);
-            })
-            .AddHostedService(sp =>
-            {
-                using var scope = sp.CreateScope();
-
-                var options = scope.ServiceProvider.GetRequiredService<IOptions<MediatorOptions>>().Value;
-                return ActivatorUtilities.CreateInstance<BackgroundCommandSenderHostedService>(scope.ServiceProvider, options.CommandWorkerCount);
-            })
-            .AddHostedService(sp =>
-            {
-                using var scope = sp.CreateScope();
-
-                var options = scope.ServiceProvider.GetRequiredService<IOptions<MediatorOptions>>().Value;
-                return ActivatorUtilities.CreateInstance<BackgroundEventPublisherHostedService>(scope.ServiceProvider, options.NotificationWorkerCount);
-            });
+            .AddHostedService<JobRunnerHostedService>()
+            .AddHostedService<BackgroundCommandSenderHostedService>()
+            .AddHostedService<BackgroundEventPublisherHostedService>();
     }
 
     /// <summary>
diff --git a/src/common/Elsa.Mediator/HostedServices/BackgroundCommandSenderHostedService.cs b/src/common/Elsa.Mediator/HostedServices/BackgroundCommandSenderHostedService.cs
index 6b5092dbc..8b4a0db0c 100644
--- a/src/common/Elsa.Mediator/HostedServices/BackgroundCommandSenderHostedService.cs
+++ b/src/common/Elsa.Mediator/HostedServices/BackgroundCommandSenderHostedService.cs
@@ -1,8 +1,10 @@
 using System.Threading.Channels;
 using Elsa.Mediator.Contracts;
+using Elsa.Mediator.Options;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
 
 namespace Elsa.Mediator.HostedServices;
 
@@ -18,13 +20,13 @@ public class BackgroundCommandSenderHostedService : BackgroundService
     private readonly ILogger _logger;
 
     /// <inheritdoc />
-    public BackgroundCommandSenderHostedService(int workerCount, ICommandsChannel commandsChannel, IServiceScopeFactory scopeFactory, ILogger<BackgroundCommandSenderHostedService> logger)
+    public BackgroundCommandSenderHostedService(IOptions<MediatorOptions> options, ICommandsChannel commandsChannel, IServiceScopeFactory scopeFactory, ILogger<BackgroundCommandSenderHostedService> logger)
     {
-        _workerCount = workerCount;
+        _workerCount = options.Value.CommandWorkerCount;
         _commandsChannel = commandsChannel;
         _scopeFactory = scopeFactory;
         _logger = logger;
-        _outputs = new List<Channel<ICommand>>(workerCount);
+        _outputs = new List<Channel<ICommand>>(_workerCount);
     }
 
     /// <inheritdoc />
diff --git a/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs b/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs
index 19d6e686d..67e43ddfb 100644
--- a/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs
+++ b/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs
@@ -1,8 +1,10 @@
 using System.Threading.Channels;
 using Elsa.Mediator.Contracts;
+using Elsa.Mediator.Options;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
 
 namespace Elsa.Mediator.HostedServices;
 
@@ -18,13 +20,13 @@ public class BackgroundEventPublisherHostedService : BackgroundService
     private readonly ILogger _logger;
 
     /// <inheritdoc />
-    public BackgroundEventPublisherHostedService(int workerCount, INotificationsChannel notificationsChannel, IServiceScopeFactory scopeFactory, ILogger<BackgroundEventPublisherHostedService> logger)
+    public BackgroundEventPublisherHostedService(IOptions<MediatorOptions> options, INotificationsChannel notificationsChannel, IServiceScopeFactory scopeFactory, ILogger<BackgroundEventPublisherHostedService> logger)
     {
-        _workerCount = workerCount;
+        _workerCount = options.Value.NotificationWorkerCount;
         _notificationsChannel = notificationsChannel;
         _scopeFactory = scopeFactory;
         _logger = logger;
-        _outputs = new List<Channel<INotification>>(workerCount);
+        _outputs = new List<Channel<INotification>>(_workerCount);
     }
 
     /// <inheritdoc />
diff --git a/src/common/Elsa.Mediator/HostedServices/JobRunnerHostedService.cs b/src/common/Elsa.Mediator/HostedServices/JobRunnerHostedService.cs
index b759367b1..4eeec9061 100644
--- a/src/common/Elsa.Mediator/HostedServices/JobRunnerHostedService.cs
+++ b/src/common/Elsa.Mediator/HostedServices/JobRunnerHostedService.cs
@@ -1,6 +1,8 @@
 using Elsa.Mediator.Contracts;
+using Elsa.Mediator.Options;
 using Microsoft.Extensions.Hosting;
 using Microsoft.Extensions.Logging;
+using Microsoft.Extensions.Options;
 
 namespace Elsa.Mediator.HostedServices;
 
@@ -14,9 +16,9 @@ public class JobRunnerHostedService : BackgroundService
     private readonly ILogger<JobRunnerHostedService> _logger;
 
     /// <inheritdoc />
-    public JobRunnerHostedService(int workerCount, IJobsChannel jobsChannel, ILogger<JobRunnerHostedService> logger)
+    public JobRunnerHostedService(IOptions<MediatorOptions> options, IJobsChannel jobsChannel, ILogger<JobRunnerHostedService> logger)
     {
-        _workerCount = workerCount;
+        _workerCount = options.Value.JobWorkerCount;
         _jobsChannel = jobsChannel;
         _logger = logger;
     }