diff --git a/src/Rebus.Correlate/Rebus.Correlate.csproj b/src/Rebus.Correlate/Rebus.Correlate.csproj
index e7716dd..db96006 100644
--- a/src/Rebus.Correlate/Rebus.Correlate.csproj
+++ b/src/Rebus.Correlate/Rebus.Correlate.csproj
@@ -18,7 +18,7 @@
-
+
diff --git a/test/Rebus.Correlate.Tests/Fixtures/RebusFixture.cs b/test/Rebus.Correlate.Tests/Fixtures/RebusFixture.cs
index e361868..d4db762 100644
--- a/test/Rebus.Correlate.Tests/Fixtures/RebusFixture.cs
+++ b/test/Rebus.Correlate.Tests/Fixtures/RebusFixture.cs
@@ -16,7 +16,18 @@ protected RebusFixture()
{
_configureActions.Add(configurer => configurer
.Transport(t => t.UseInMemoryTransport(new InMemNetwork(), "input"))
- .Subscriptions(s => s.StoreInMemory(new InMemorySubscriberStore()))
+ .Subscriptions(s =>
+ {
+ try
+ {
+ s.StoreInMemory(new InMemorySubscriberStore());
+ }
+ catch (InvalidOperationException ex) when (ex.Message.Contains("a primary registration already exists"))
+ {
+ // Newer Rebus impl. of UseInMemoryTransport() registers a subscription storage provider by default
+ // in which case we just ignore the exception.
+ }
+ })
// Route all to input.
.Routing(r => r.TypeBased().MapFallback("input"))
);
diff --git a/test/Rebus.Correlate.Tests/Rebus.Correlate.Tests.csproj b/test/Rebus.Correlate.Tests/Rebus.Correlate.Tests.csproj
index 28ef430..28c232a 100644
--- a/test/Rebus.Correlate.Tests/Rebus.Correlate.Tests.csproj
+++ b/test/Rebus.Correlate.Tests/Rebus.Correlate.Tests.csproj
@@ -6,9 +6,18 @@
Rebus.Correlate
+
+ 8.0.2
+
+
+
+
+ 7.0.0
+
+
-
+
@@ -22,4 +31,4 @@
-
\ No newline at end of file
+