diff --git a/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs b/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs
index b906092e8..e3fac5ff5 100644
--- a/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs
+++ b/src/common/Elsa.Mediator/HostedServices/BackgroundEventPublisherHostedService.cs
@@ -53,7 +53,7 @@ public class BackgroundEventPublisherHostedService : BackgroundService
         }
     }
 
-    private async Task ReadOutputAsync(Channel<INotification, INotification> output, CancellationToken cancellationToken)
+    private async Task ReadOutputAsync(Channel<INotification> output, CancellationToken cancellationToken)
     {
         await foreach (var notification in output.Reader.ReadAllAsync(cancellationToken))
         {