Another improvement.

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);
             });
         }
 

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;
         }