Removing repetition in NServiceBusConfig

Author: sadukie

src/ApplicationCore/Configuration/NServiceBusConfiguration.cs

@@ -0,0 +1,23 @@
+using Microsoft.eShopWeb.ApplicationCore.Entities.OrderAggregate.Events;
+using NServiceBus;
+
+namespace Microsoft.eShopWeb.ApplicationCore.Configuration;
+public static class NServiceBusConfiguration
+{
+    public static EndpointConfiguration GetNServiceBusConfiguration()
+    {
+        var endpointConfiguration = new EndpointConfiguration("orders-worker");
+        endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+
+        var transport = endpointConfiguration.UseTransport<LearningTransport>();
+
+        transport.Routing().RouteToEndpoint(
+          typeof(OrderCreatedEvent),
+          "orders-worker");
+
+        endpointConfiguration.SendFailedMessagesTo("error");
+        endpointConfiguration.AuditProcessedMessagesTo("audit");
+
+        return endpointConfiguration;
+    }
+}

src/Web/Program.cs

@@ -12,6 +12,7 @@
 using Microsoft.eShopWeb.Web.Extensions;
 using NServiceBus;
 using NimblePros.Metronome;
+using Microsoft.eShopWeb.ApplicationCore.Configuration;
 
 var builder = WebApplication.CreateBuilder(args);
 
@@ -52,22 +53,7 @@
 }
 
 // NServiceBus
-builder.Host.UseNServiceBus(_ =>
-{
-    var endpointConfiguration = new EndpointConfiguration("orders-worker");
-    endpointConfiguration.UseSerialization<SystemJsonSerializer>();
-
-    var transport = endpointConfiguration.UseTransport<LearningTransport>();
-
-    transport.Routing().RouteToEndpoint(
-      typeof(OrderCreatedEvent),
-      "orders-worker");
-
-    endpointConfiguration.SendFailedMessagesTo("error");
-    endpointConfiguration.AuditProcessedMessagesTo("audit");
-
-    return endpointConfiguration;
-});
+builder.Host.UseNServiceBus( config => NServiceBusConfiguration.GetNServiceBusConfiguration());
 
 builder.Services.AddScoped<ITokenClaimsService, IdentityTokenClaimService>();
 builder.Services.AddCoreServices(builder.Configuration);

src/eShopOnWeb.Worker/Program.cs

@@ -1,20 +1,11 @@
 using System.Text.Json;
+using Microsoft.eShopWeb.ApplicationCore.Configuration;
 using NServiceBus;
 
 var builder = Host.CreateDefaultBuilder();
 
 builder.UseConsoleLifetime();
-builder.UseNServiceBus(context =>
-{
-    var endpointConfiguration = new EndpointConfiguration("orders-worker");
-    endpointConfiguration.UseSerialization<SystemJsonSerializer>();
-    endpointConfiguration.UseTransport<LearningTransport>();
-
-    endpointConfiguration.SendFailedMessagesTo("error");
-    endpointConfiguration.AuditProcessedMessagesTo("audit");
-
-    return endpointConfiguration;
-});
+builder.UseNServiceBus(context => NServiceBusConfiguration.GetNServiceBusConfiguration());
 
 var host = builder.Build();
 host.Run();