From b5055380923d0a4a9f38fe287ffb19c7c0be817b Mon Sep 17 00:00:00 2001
From: Sebastian Stehle <sebastian@squidex.io>
Date: Mon, 8 Apr 2019 14:49:41 +0200
Subject: [PATCH] Another improvement.

---
 src/Squidex.Infrastructure/PubSubExtensions.cs                  | 2 +-
 .../EventSourcing/RetrySubscriptionTests.cs                     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

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