Update blob-storage-databus-cleanup-function sample to NServiceBus 10

- Migrate SenderAndReceiver from .NET 9 to .NET 10 preview
- Keep Azure Functions on .NET 9 (Azure Functions doesn't support .NET 10 yet)
- Update NServiceBus packages to 10.0.0-alpha.1 versions
- Migrate from DataBus to ClaimCheck API (NServiceBus.ClaimCheck 2.0.0-alpha.1)
- Replace DataBusProperty<T> with regular byte[] properties
- Remove InputLoopService pattern and modernize Program.cs
- Update ClaimCheck configuration with SystemJsonClaimCheckSerializer
- Add prerelease.txt marker file

Fixes: #7288

Author: cquirosj

samples/databus/blob-storage-databus-cleanup-function/ABSDataBus_7/DataBusBlobCleanupFunctions/DataBusBlobCleanupFunctions.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>net9.0;net8.0</TargetFrameworks>
+    <TargetFramework>net9.0</TargetFramework>
     <AzureFunctionsVersion>v4</AzureFunctionsVersion>
     <LangVersion>12.0</LangVersion>
     <OutputType>Exe</OutputType>

samples/databus/blob-storage-databus-cleanup-function/ABSDataBus_7/SenderAndReceiver/InputLoopService.cs

@@ -3,8 +3,6 @@
 [TimeToBeReceived("00:00:10")]
 public class MessageWithLargePayload : ICommand
 {
-#pragma warning disable CS0618 // Type or member is obsolete
-    public DataBusProperty<byte[]> LargePayload { get; set; }
-#pragma warning restore CS0618 // Type or member is obsolete
+    public byte[] LargePayload { get; set; }
     public string Description { get; set; }
 }

samples/databus/blob-storage-databus-cleanup-function/ABSDataBus_7/SenderAndReceiver/MessageWithLargePayload.cs

@@ -7,9 +7,7 @@ public class MessageWithLargePayloadHandler(ILogger<MessageWithLargePayloadHandl
 
     public Task Handle(MessageWithLargePayload message, IMessageHandlerContext context)
     {
-        #pragma warning disable CS0618 // Type or member is obsolete
-        logger.LogInformation("Message received. Description: '{Description}'. Size of payload property: {PayloadSize} Bytes", message.Description, message.LargePayload.Value.Length);
-        #pragma warning restore CS0618 // Type or member is obsolete
+        logger.LogInformation("Message received. Description: '{Description}'. Size of payload property: {PayloadSize} Bytes", message.Description, message.LargePayload.Length);
         return Task.CompletedTask;
     }
 }

samples/databus/blob-storage-databus-cleanup-function/ABSDataBus_7/SenderAndReceiver/MessageWithLargePayloadHandler.cs

@@ -1,24 +1,58 @@
 using System;
 using System.Threading.Tasks;
+using Azure.Storage.Blobs;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
 using NServiceBus;
-using SenderAndReceiver;
 
 Console.Title = "SenderAndReceiver";
 
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
 var endpointConfiguration = new EndpointConfiguration("Samples.AzureDataBusCleanupWithFunctions.SenderAndReceiver");
 
-#pragma warning disable CS0618 // Type or member is obsolete
-var dataBus = endpointConfiguration.UseDataBus<AzureDataBus, SystemJsonDataBusSerializer>();
-#pragma warning restore CS0618 // Type or member is obsolete
-dataBus.ConnectionString("UseDevelopmentStorage=true");
+var blobServiceClient = new BlobServiceClient("UseDevelopmentStorage=true");
+var claimCheck = endpointConfiguration.UseClaimCheck<AzureClaimCheck, SystemJsonClaimCheckSerializer>()
+    .Container("testcontainer")
+    .UseBlobServiceClient(blobServiceClient);
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
-endpointConfiguration.UseTransport<LearningTransport>();
+endpointConfiguration.UseTransport(new LearningTransport());
 endpointConfiguration.EnableInstallers();
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+Console.WriteLine("Press 'Enter' to send a large message (>4MB)");
+while (true)
+{
+    var key = Console.ReadKey();
+
+    if (key.Key == ConsoleKey.Enter)
+    {
+        await SendMessageLargePayload(messageSession);
+    }
+    else
+    {
+        break;
+    }
+}
+
+await host.StopAsync();
+
+static async Task SendMessageLargePayload(IMessageSession messageSession)
+{
+    Console.WriteLine("Sending message...");
+
+    var message = new MessageWithLargePayload
+    {
+        Description = "This message contains a large payload that will be sent on the Azure data bus",
+        LargePayload = new byte[1024 * 1024 * 5] // 5MB
+    };
+
+    await messageSession.SendLocal(message);
+
+    Console.WriteLine("Message sent.");
+}

samples/databus/blob-storage-databus-cleanup-function/ABSDataBus_7/SenderAndReceiver/Program.cs

@@ -1,15 +1,16 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>net9.0;net8.0</TargetFrameworks>
+    <TargetFramework>net10.0</TargetFramework>
     <OutputType>Exe</OutputType>
-    <LangVersion>12.0</LangVersion>
+    <LangVersion>preview</LangVersion>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="NServiceBus" Version="9.*" />
-    <PackageReference Include="NServiceBus.DataBus.AzureBlobStorage" Version="6.0.*" />
-    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="3.0.1" />
+    <PackageReference Include="NServiceBus" Version="10.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.ClaimCheck" Version="2.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.DataBus.AzureBlobStorage" Version="7.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="4.0.0-alpha.1" />
   </ItemGroup>
 
 </Project>