Update NServiceBus Core to 10.0.0-alpha.7 (#1601)

dependencyupdates[bot] · web-flow · commit bcaeec953213 · 2025-11-05T15:06:55.000Z
Co-authored-by: dependencyupdates[bot] &lt;218638057+dependencyupdates[bot]@users.noreply.github.com&gt;
diff --git a/src/NServiceBus.Transport.PostgreSql.AcceptanceTests/NServiceBus.Transport.PostgreSql.AcceptanceTests.csproj b/src/NServiceBus.Transport.PostgreSql.AcceptanceTests/NServiceBus.Transport.PostgreSql.AcceptanceTests.csproj
@@ -13,7 +13,7 @@
   <ItemGroup>
     <PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.0" />
-    <PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.6" GeneratePathProperty="true" />
+    <PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.10" GeneratePathProperty="true" />
     <PackageReference Include="NUnit" Version="4.4.0" />
     <PackageReference Include="NUnit.Analyzers" Version="4.11.2" />
     <PackageReference Include="NUnit3TestAdapter" Version="5.2.0" />
diff --git a/src/NServiceBus.Transport.PostgreSql.TransportTests/NServiceBus.Transport.PostgreSql.TransportTests.csproj b/src/NServiceBus.Transport.PostgreSql.TransportTests/NServiceBus.Transport.PostgreSql.TransportTests.csproj
@@ -13,7 +13,7 @@
   <ItemGroup>
     <PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.0" />
-    <PackageReference Include="NServiceBus.TransportTests.Sources" Version="10.0.0-alpha.6" GeneratePathProperty="true" />
+    <PackageReference Include="NServiceBus.TransportTests.Sources" Version="10.0.0-alpha.10" GeneratePathProperty="true" />
     <PackageReference Include="NUnit" Version="4.4.0" />
     <PackageReference Include="NUnit.Analyzers" Version="4.11.2" />
     <PackageReference Include="NUnit3TestAdapter" Version="5.2.0" />
diff --git a/src/NServiceBus.Transport.PostgreSql/NServiceBus.Transport.PostgreSql.csproj b/src/NServiceBus.Transport.PostgreSql/NServiceBus.Transport.PostgreSql.csproj
@@ -12,7 +12,7 @@
 
   <ItemGroup>
     <PackageReference Include="Npgsql" Version="9.0.3" AutomaticVersionRange="false" />
-    <PackageReference Include="NServiceBus" Version="10.0.0-alpha.6" />
+    <PackageReference Include="NServiceBus" Version="10.0.0-alpha.10" />
   </ItemGroup>
 
   <ItemGroup>
diff --git a/src/NServiceBus.Transport.SqlServer.AcceptanceTests/NServiceBus.Transport.SqlServer.AcceptanceTests.csproj b/src/NServiceBus.Transport.SqlServer.AcceptanceTests/NServiceBus.Transport.SqlServer.AcceptanceTests.csproj
@@ -13,7 +13,7 @@
   <ItemGroup>
     <PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.0" />
-    <PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.6" GeneratePathProperty="true" />
+    <PackageReference Include="NServiceBus.AcceptanceTests.Sources" Version="10.0.0-alpha.10" GeneratePathProperty="true" />
     <PackageReference Include="NUnit" Version="4.4.0" />
     <PackageReference Include="NUnit.Analyzers" Version="4.11.2" />
     <PackageReference Include="NUnit3TestAdapter" Version="5.2.0" />
diff --git a/src/NServiceBus.Transport.SqlServer.AcceptanceTests/TestingInMemoryPersistence.cs b/src/NServiceBus.Transport.SqlServer.AcceptanceTests/TestingInMemoryPersistence.cs
@@ -13,23 +13,15 @@
 using NServiceBus.Unicast.Subscriptions;
 using NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions;
 
-public class TestingInMemoryPersistence : PersistenceDefinition
+public class TestingInMemoryPersistence : PersistenceDefinition, IPersistenceDefinitionFactory<TestingInMemoryPersistence>
 {
-    internal TestingInMemoryPersistence()
-    {
-        Supports<StorageType.Subscriptions>(s =>
-        {
-            s.EnableFeatureByDefault<TestingInMemorySubscriptionPersistence>();
-        });
-    }
+    TestingInMemoryPersistence() => Supports<StorageType.Subscriptions, TestingInMemorySubscriptionPersistence>();
+    public static TestingInMemoryPersistence Create() => new();
 }
 
 public static class InMemoryPersistenceExtensions
 {
-    public static void UseStorage(this PersistenceExtensions<TestingInMemoryPersistence> extensions, TestingInMemorySubscriptionStorage storageInstance)
-    {
-        extensions.GetSettings().Set("InMemoryPersistence.StorageInstance", storageInstance);
-    }
+    public static void UseStorage(this PersistenceExtensions<TestingInMemoryPersistence> extensions, TestingInMemorySubscriptionStorage storageInstance) => extensions.GetSettings().Set("InMemoryPersistence.StorageInstance", storageInstance);
 }
 
 public class TestingInMemorySubscriptionPersistence : Feature
@@ -55,29 +47,31 @@ public Task Subscribe(Subscriber subscriber, MessageType messageType, ContextBag
         return Task.FromResult(true);
     }
 
-    static string BuildKey(Subscriber subscriber)
-    {
-        return $"{subscriber.TransportAddress ?? ""}_{subscriber.Endpoint ?? ""}";
-    }
+    static string BuildKey(Subscriber subscriber) => $"{subscriber.TransportAddress ?? ""}_{subscriber.Endpoint ?? ""}";
 
     public Task Unsubscribe(Subscriber subscriber, MessageType messageType, ContextBag context, CancellationToken cancellationToken = default)
     {
         if (storage.TryGetValue(messageType, out var dict))
         {
             dict.TryRemove(BuildKey(subscriber), out var _);
         }
+
         return Task.FromResult(true);
     }
 
     public Task<IEnumerable<Subscriber>> GetSubscriberAddressesForMessage(IEnumerable<MessageType> messageTypes, ContextBag context, CancellationToken cancellationToken = default)
     {
         var subscribers = messageTypes
             .SelectMany(msgType => storage.TryGetValue(msgType, out var subs) ? subs.Values : [])
-            .GroupBy(s => new { s.TransportAddress, s.Endpoint }) // Subscriber does not implement IEquatable<T>
+            .GroupBy(s => new
+            {
+                s.TransportAddress,
+                s.Endpoint
+            }) // Subscriber does not implement IEquatable<T>
             .Select(g => g.First());
 
         return Task.FromResult(subscribers);
     }
 
-    ConcurrentDictionary<MessageType, ConcurrentDictionary<string, Subscriber>> storage = new ConcurrentDictionary<MessageType, ConcurrentDictionary<string, Subscriber>>();
-}
+    readonly ConcurrentDictionary<MessageType, ConcurrentDictionary<string, Subscriber>> storage = new();
+}
diff --git a/src/NServiceBus.Transport.SqlServer.TransportTests/NServiceBus.Transport.SqlServer.TransportTests.csproj b/src/NServiceBus.Transport.SqlServer.TransportTests/NServiceBus.Transport.SqlServer.TransportTests.csproj
@@ -13,7 +13,7 @@
   <ItemGroup>
     <PackageReference Include="GitHubActionsTestLogger" Version="2.4.1" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="18.0.0" />
-    <PackageReference Include="NServiceBus.TransportTests.Sources" Version="10.0.0-alpha.6" />
+    <PackageReference Include="NServiceBus.TransportTests.Sources" Version="10.0.0-alpha.10" />
     <PackageReference Include="NUnit" Version="4.4.0" />
     <PackageReference Include="NUnit.Analyzers" Version="4.11.2" />
     <PackageReference Include="NUnit3TestAdapter" Version="5.2.0" />
diff --git a/src/NServiceBus.Transport.SqlServer/NServiceBus.Transport.SqlServer.csproj b/src/NServiceBus.Transport.SqlServer/NServiceBus.Transport.SqlServer.csproj
@@ -12,7 +12,7 @@
 
   <ItemGroup>
     <PackageReference Include="Microsoft.Data.SqlClient" Version="6.1.1" AutomaticVersionRange="false" />
-    <PackageReference Include="NServiceBus" Version="10.0.0-alpha.6" />
+    <PackageReference Include="NServiceBus" Version="10.0.0-alpha.10" />
   </ItemGroup>
 
   <ItemGroup>

Original file line number	Diff line number	Diff line change
`@@ -13,23 +13,15 @@`
`13`	`13`	`using NServiceBus.Unicast.Subscriptions;`
`14`	`14`	`using NServiceBus.Unicast.Subscriptions.MessageDrivenSubscriptions;`
`15`	`15`
`16`		`-public class TestingInMemoryPersistence : PersistenceDefinition`
	`16`	`+public class TestingInMemoryPersistence : PersistenceDefinition, IPersistenceDefinitionFactory<TestingInMemoryPersistence>`
`17`	`17`	`{`
`18`		`- internal TestingInMemoryPersistence()`
`19`		`- {`
`20`		`- Supports<StorageType.Subscriptions>(s =>`
`21`		`- {`
`22`		`- s.EnableFeatureByDefault<TestingInMemorySubscriptionPersistence>();`
`23`		`- });`
`24`		`- }`
	`18`	`+ TestingInMemoryPersistence() => Supports<StorageType.Subscriptions, TestingInMemorySubscriptionPersistence>();`
	`19`	`+ public static TestingInMemoryPersistence Create() => new();`
`25`	`20`	`}`
`26`	`21`
`27`	`22`	`public static class InMemoryPersistenceExtensions`
`28`	`23`	`{`
`29`		`- public static void UseStorage(this PersistenceExtensions<TestingInMemoryPersistence> extensions, TestingInMemorySubscriptionStorage storageInstance)`
`30`		`- {`
`31`		`- extensions.GetSettings().Set("InMemoryPersistence.StorageInstance", storageInstance);`
`32`		`- }`
	`24`	`+ public static void UseStorage(this PersistenceExtensions<TestingInMemoryPersistence> extensions, TestingInMemorySubscriptionStorage storageInstance) => extensions.GetSettings().Set("InMemoryPersistence.StorageInstance", storageInstance);`
`33`	`25`	`}`
`34`	`26`
`35`	`27`	`public class TestingInMemorySubscriptionPersistence : Feature`
`@@ -55,29 +47,31 @@ public Task Subscribe(Subscriber subscriber, MessageType messageType, ContextBag`
`55`	`47`	`return Task.FromResult(true);`
`56`	`48`	`}`
`57`	`49`
`58`		`- static string BuildKey(Subscriber subscriber)`
`59`		`- {`
`60`		`- return $"{subscriber.TransportAddress ?? ""}_{subscriber.Endpoint ?? ""}";`
`61`		`- }`
	`50`	`+ static string BuildKey(Subscriber subscriber) => $"{subscriber.TransportAddress ?? ""}_{subscriber.Endpoint ?? ""}";`
`62`	`51`
`63`	`52`	`public Task Unsubscribe(Subscriber subscriber, MessageType messageType, ContextBag context, CancellationToken cancellationToken = default)`
`64`	`53`	`{`
`65`	`54`	`if (storage.TryGetValue(messageType, out var dict))`
`66`	`55`	`{`
`67`	`56`	`dict.TryRemove(BuildKey(subscriber), out var _);`
`68`	`57`	`}`
	`58`	`+`
`69`	`59`	`return Task.FromResult(true);`
`70`	`60`	`}`
`71`	`61`
`72`	`62`	`public Task<IEnumerable<Subscriber>> GetSubscriberAddressesForMessage(IEnumerable<MessageType> messageTypes, ContextBag context, CancellationToken cancellationToken = default)`
`73`	`63`	`{`
`74`	`64`	`var subscribers = messageTypes`
`75`	`65`	`.SelectMany(msgType => storage.TryGetValue(msgType, out var subs) ? subs.Values : [])`
`76`		`- .GroupBy(s => new { s.TransportAddress, s.Endpoint }) // Subscriber does not implement IEquatable<T>`
	`66`	`+ .GroupBy(s => new`
	`67`	`+ {`
	`68`	`+ s.TransportAddress,`
	`69`	`+ s.Endpoint`
	`70`	`+ }) // Subscriber does not implement IEquatable<T>`
`77`	`71`	`.Select(g => g.First());`
`78`	`72`
`79`	`73`	`return Task.FromResult(subscribers);`
`80`	`74`	`}`
`81`	`75`
`82`		`- ConcurrentDictionary<MessageType, ConcurrentDictionary<string, Subscriber>> storage = new ConcurrentDictionary<MessageType, ConcurrentDictionary<string, Subscriber>>();`
`83`		`-}`
	`76`	`+ readonly ConcurrentDictionary<MessageType, ConcurrentDictionary<string, Subscriber>> storage = new();`
	`77`	`+}`