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 +