diff --git a/src/Squidex.Infrastructure/PubSubExtensions.cs b/src/Squidex.Infrastructure/PubSubExtensions.cs
index 2cc80120a..66fa534f7 100644
--- a/src/Squidex.Infrastructure/PubSubExtensions.cs
+++ b/src/Squidex.Infrastructure/PubSubExtensions.cs
@@ -37,7 +37,7 @@ namespace Squidex.Infrastructure
             {
                 var response = await callback(x.Body);
 
-                pubsub.Publish(new Response<TResponse> { CorrelationId = x.CorrelationId, Body = response }, true);
+                pubsub.Publish(new Response<TResponse> { CorrelationId = x.CorrelationId, Body = response }, self);
             });
         }
 
diff --git a/tests/Squidex.Infrastructure.Tests/EventSourcing/RetrySubscriptionTests.cs b/tests/Squidex.Infrastructure.Tests/EventSourcing/RetrySubscriptionTests.cs
index 203730710..95d3759d0 100644
--- a/tests/Squidex.Infrastructure.Tests/EventSourcing/RetrySubscriptionTests.cs
+++ b/tests/Squidex.Infrastructure.Tests/EventSourcing/RetrySubscriptionTests.cs
@@ -25,7 +25,7 @@ namespace Squidex.Infrastructure.EventSourcing
         {
             A.CallTo(() => eventStore.CreateSubscription(A<IEventSubscriber>.Ignored, A<string>.Ignored, A<string>.Ignored)).Returns(eventSubscription);
 
-            sut = new RetrySubscription(eventStore, eventSubscriber, streamFilter, null) { ReconnectWaitMs = 100 };
+            sut = new RetrySubscription(eventStore, eventSubscriber, streamFilter, null) { ReconnectWaitMs = 50 };
 
             sutSubscriber = sut;
         }