Merge pull request #7479 from Particular/serializers-xml-sample-update

Serializers xml sample update

Author: tmasternak

samples/serializers/xml/Core_10/Sample/CreateOrder.cs

@@ -0,0 +1,13 @@
+using System;
+using System.Collections.Generic;
+using NServiceBus;
+
+
+public class CreateOrder :
+    IMessage
+{
+    public int OrderId { get; set; }
+    public DateTime Date { get; set; }
+    public int CustomerId { get; set; }
+    public List<OrderItem> OrderItems { get; set; }
+}

samples/serializers/xml/Core_10/Sample/CreateOrderHandler.cs

@@ -0,0 +1,13 @@
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+public class CreateOrderHandler(ILogger<CreateOrderHandler> logger) :
+    IHandleMessages<CreateOrder>
+{
+    public Task Handle(CreateOrder message, IMessageHandlerContext context)
+    {
+        logger.LogInformation("Order received");
+        return Task.CompletedTask;
+    }
+}

samples/serializers/xml/Core_10/Sample/MessageBodyWriter.cs

@@ -0,0 +1,20 @@
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using NServiceBus.MessageMutator;
+
+#region mutator
+public class MessageBodyWriter(ILogger<MessageBodyWriter> logger) :
+    IMutateIncomingTransportMessages
+{
+    public Task MutateIncoming(MutateIncomingTransportMessageContext context)
+    {
+        var bodyAsString = Encoding.UTF8.GetString(context.Body.ToArray());
+
+        logger.LogInformation("Serialized Message Body:");
+        logger.LogInformation(bodyAsString);
+
+        return Task.CompletedTask;
+    }
+}
+#endregion

samples/serializers/xml/Core_10/Sample/OrderItem.cs

@@ -0,0 +1,6 @@
+
+public class OrderItem
+{
+    public int ItemId { get; set; }
+    public int Quantity { get; set; }
+}

samples/serializers/xml/Core_10/Sample/Program.cs

@@ -0,0 +1,69 @@
+using System;
+using System.Collections.Generic;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using NServiceBus;
+using NServiceBus.MessageMutator;
+
+
+Console.Title = "Xml";
+
+var builder = Host.CreateApplicationBuilder(args);
+
+#region config
+var endpointConfiguration = new EndpointConfiguration("Samples.Serialization.Xml");
+
+endpointConfiguration.UseSerialization<XmlSerializer>();
+
+
+// Then later get it from the service provider when needed
+builder.Services.AddSingleton<MessageBodyWriter>();
+var serviceProvider = builder.Services.BuildServiceProvider();
+var messageBodyWriter = serviceProvider.GetRequiredService<MessageBodyWriter>();
+
+// register the mutator so the the message on the wire is written
+endpointConfiguration.RegisterMessageMutator(messageBodyWriter);
+
+#endregion
+
+endpointConfiguration.UseTransport(new LearningTransport());
+
+Console.WriteLine("Press any key, the application is starting");
+Console.ReadKey();
+Console.WriteLine("Starting...");
+
+builder.UseNServiceBus(endpointConfiguration);
+var host = builder.Build();
+
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+#region message
+var message = new CreateOrder
+{
+    OrderId = 9,
+    Date = DateTime.Now,
+    CustomerId = 12,
+    OrderItems = new List<OrderItem>
+    {
+        new OrderItem
+        {
+            ItemId = 6,
+            Quantity = 2
+        },
+        new OrderItem
+        {
+            ItemId = 5,
+            Quantity = 4
+        },
+    }
+};
+
+await messageSession.SendLocal(message);
+
+#endregion
+
+Console.WriteLine("Order Sent");
+
+await host.StopAsync();

samples/serializers/xml/Core_10/Sample/Sample.csproj

@@ -0,0 +1,11 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <OutputType>Exe</OutputType>
+    <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" />
+  </ItemGroup>
+</Project>

samples/serializers/xml/Core_10/XmlSample.sln

@@ -0,0 +1,19 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 16
+VisualStudioVersion = 16.0.29728.190
+MinimumVisualStudioVersion = 15.0.26730.12
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Sample", "Sample\Sample.csproj", "{6E6C9C2A-8D9B-41AF-B5E5-1AF5310686E7}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{6E6C9C2A-8D9B-41AF-B5E5-1AF5310686E7}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{6E6C9C2A-8D9B-41AF-B5E5-1AF5310686E7}.Debug|Any CPU.Build.0 = Debug|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+EndGlobal

samples/serializers/xml/Core_10/prerelease.txt

@@ -4,13 +4,11 @@
 using Microsoft.Extensions.Hosting;
 using NServiceBus;
 using NServiceBus.MessageMutator;
-using Sample;
 
 
 Console.Title = "Xml";
 
 var builder = Host.CreateApplicationBuilder(args);
-builder.Services.AddHostedService<InputLoopService>();
 
 #region config
 var endpointConfiguration = new EndpointConfiguration("Samples.Serialization.Xml");
@@ -35,4 +33,38 @@
 Console.WriteLine("Starting...");
 
 builder.UseNServiceBus(endpointConfiguration);
-await builder.Build().RunAsync();
+
+var host = builder.Build();
+
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+#region message
+var message = new CreateOrder
+{
+    OrderId = 9,
+    Date = DateTime.Now,
+    CustomerId = 12,
+    OrderItems = new List<OrderItem>
+    {
+        new OrderItem
+        {
+            ItemId = 6,
+            Quantity = 2
+        },
+        new OrderItem
+        {
+            ItemId = 5,
+            Quantity = 4
+        },
+    }
+};
+
+await messageSession.SendLocal(message);
+
+#endregion
+
+Console.WriteLine("Order Sent");
+
+await host.StopAsync();