Update databus custom-serializer to NServiceBus 10 (#7514)

Author: cquirosj

samples/databus/custom-serializer/Core_9/Sender/InputLoopService.cs

@@ -1,30 +1,29 @@
 using NServiceBus;
 using Shared;
 using System;
-using System.Threading.Tasks;
 using NServiceBus.ClaimCheck;
 using Microsoft.Extensions.Hosting;
 
-
 Console.Title = "Receiver";
 var builder = Host.CreateApplicationBuilder(args);
-
 var endpointConfiguration = new EndpointConfiguration("Samples.DataBus.Receiver");
 
 #region ConfigureReceiverCustomDataBusSerializer
 
 var claimCheck = endpointConfiguration.UseClaimCheck<FileShareClaimCheck, BsonClaimCheckSerializer>();
-claimCheck.BasePath(@"..\..\..\..\storage");
+claimCheck.BasePath(SolutionDirectoryFinder.Find("storage"));
 
 #endregion
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.UseTransport(new LearningTransport());
 
-Console.WriteLine("Press any key, the application is starting");
-Console.ReadKey();
-Console.WriteLine("Starting...");
-
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+await host.StartAsync();
+
+Console.WriteLine("Press any key to exit");
+Console.ReadKey();
+
+await host.StopAsync();

samples/databus/custom-serializer/Core_9/Sender/Program.cs

@@ -2,23 +2,73 @@
 using Shared;
 using System;
 using Microsoft.Extensions.Hosting;
-using Sender;
 using Microsoft.Extensions.DependencyInjection;
-
+using System.Threading.Tasks;
+using System.Collections.Generic;
+using System.Linq;
+using NServiceBus.ClaimCheck;
 
 Console.Title = "Sender";
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
 var endpointConfiguration = new EndpointConfiguration("Samples.DataBus.Sender");
 
 #region ConfigureSenderCustomDataBusSerializer
 
 var claimCheck = endpointConfiguration.UseClaimCheck<FileShareClaimCheck, BsonClaimCheckSerializer>();
-claimCheck.BasePath(@"..\..\..\..\storage");
+claimCheck.BasePath(SolutionDirectoryFinder.Find("storage"));
 
 #endregion
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+endpointConfiguration.UseTransport(new LearningTransport());
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var app = builder.Build();
+
+await app.StartAsync();
+
+var messageSession = app.Services.GetRequiredService<IMessageSession>();
+
+Console.WriteLine("Press Enter to send a large message with claim check");
+Console.WriteLine("Press any other key to exit");
+
+while (true)
+{
+    var key = Console.ReadKey(true);
+    Console.WriteLine();
+
+    if (key.Key == ConsoleKey.Enter)
+    {
+        await SendMessageLargePayload(messageSession);
+        continue;
+    }
+    break;
+}
+
+await app.StopAsync();
+
+static Task SendMessageLargePayload(IMessageSession messageSession)
+{
+    var measurements = GetMeasurements().ToArray();
+
+    var message = new MessageWithLargePayload
+    {
+        SomeProperty = "This message contains a large collection that will be sent on the claim check",
+        LargeData = new ClaimCheckProperty<Measurement[]>(measurements)
+    };
+    Console.WriteLine($"Message sent, the payload is stored in: {SolutionDirectoryFinder.Find("storage")}");
+    return messageSession.Send("Samples.DataBus.Receiver", message);
+}
+
+static IEnumerable<Measurement> GetMeasurements()
+{
+    for (var i = 0; i < 10000; i++)
+    {
+        yield return new Measurement
+        {
+            Timestamp = DateTimeOffset.UtcNow,
+            MeasurementName = $"Instrument {i}",
+            MeasurementValue = i * 10m
+        };
+    }
+}

samples/databus/custom-serializer/DataBus_1/Receiver/Program.cs

@@ -0,0 +1,33 @@
+using System;
+using System.IO;
+
+namespace Shared;
+
+public static class SolutionDirectoryFinder
+{
+    public static string Find(string solutionRelativePath = null)
+    {
+        var directory = new DirectoryInfo(Directory.GetCurrentDirectory());
+        while (directory != null && !ContainsSolutionFile(directory))
+        {
+            directory = directory.Parent;
+        }
+
+        if (directory == null)
+        {
+            throw new Exception("Could not find solution directory");
+        }
+
+        if (string.IsNullOrEmpty(solutionRelativePath))
+        {
+            return directory.FullName;
+        }
+
+        return Path.Combine(directory.FullName, solutionRelativePath);
+    }
+
+    static bool ContainsSolutionFile(DirectoryInfo directory)
+    {
+        return directory.GetFiles("*.sln").Length > 0;
+    }
+}

samples/databus/custom-serializer/DataBus_1/Sender/InputLoopService.cs

@@ -9,9 +9,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 containing {MeasurementCount} measurements", message.LargeData.Value.Length);
-        #pragma warning restore CS0618 // Type or member is obsolete
         return Task.CompletedTask;
     }
 }

samples/databus/custom-serializer/DataBus_1/Sender/Program.cs

@@ -1,26 +1,29 @@
+using System;
 using Microsoft.Extensions.Hosting;
 using NServiceBus;
+using NServiceBus.ClaimCheck;
 using Shared;
-using System;
-using System.Threading.Tasks;
 
 Console.Title = "Receiver";
 var builder = Host.CreateApplicationBuilder(args);
 var endpointConfiguration = new EndpointConfiguration("Samples.DataBus.Receiver");
 
-#pragma warning disable CS0618 // Type or member is obsolete
 #region ConfigureReceiverCustomDataBusSerializer
 
-var dataBus = endpointConfiguration.UseDataBus<FileShareDataBus, BsonDataBusSerializer>();
-dataBus.BasePath(@"..\..\..\..\storage");
+var claimCheck = endpointConfiguration.UseClaimCheck<FileShareClaimCheck, BsonClaimCheckSerializer>();
+claimCheck.BasePath(SolutionDirectoryFinder.Find("storage"));
 
 #endregion
-#pragma warning restore CS0618 // Type or member is obsolete
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.UseTransport(new LearningTransport());
 
-Console.ReadKey();
 builder.UseNServiceBus(endpointConfiguration);
 
-await builder.Build().RunAsync();
+var host = builder.Build();
+await host.StartAsync();
+
+Console.WriteLine("Press any key to exit");
+Console.ReadKey();
+
+await host.StopAsync();

samples/databus/custom-serializer/DataBus_1/Shared/SolutionDirectoryFinder.cs

@@ -1,12 +1,13 @@
 <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="10.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="4.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.ClaimCheck" Version="2.0.0-alpha.1" />
     <ProjectReference Include="..\Shared\Shared.csproj" />
-    <PackageReference Include="NServiceBus" Version="9.*" />
-    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="3.0.1" />
   </ItemGroup>
 </Project>