Update sqltransport-nhpersistence to v10

Author: WilliamBZA

samples/sqltransport-nhpersistence/Core_10/Receiver/Order.cs

@@ -0,0 +1,7 @@
+using System;
+
+public class Order
+{
+    public virtual Guid OrderId { get; set; }
+    public virtual decimal Value { get; set; }
+}

samples/sqltransport-nhpersistence/Core_10/Receiver/OrderLifecycleSaga.cs

@@ -0,0 +1,30 @@
+using System;
+using System.Threading.Tasks;
+using NServiceBus;
+using Microsoft.Extensions.Logging;
+
+public class OrderLifecycleSaga(ILogger<OrderLifecycleSaga> logger) :
+    Saga<OrderLifecycleSagaData>,
+    IAmStartedByMessages<OrderSubmitted>,
+    IHandleTimeouts<OrderTimeout>
+{
+   
+    protected override void ConfigureHowToFindSaga(SagaPropertyMapper<OrderLifecycleSagaData> mapper)
+    {
+        mapper.ConfigureMapping<OrderSubmitted>(msg => msg.OrderId).ToSaga(saga => saga.OrderId);
+    }
+
+    public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+    {
+        Data.OrderId = message.OrderId;
+        #region Timeout
+        return RequestTimeout<OrderTimeout>(context, TimeSpan.FromSeconds(5));
+        #endregion
+    }
+
+    public Task Timeout(OrderTimeout state, IMessageHandlerContext context)
+    {
+        logger.LogInformation("Got timeout");
+        return Task.CompletedTask;
+    }
+}

samples/sqltransport-nhpersistence/Core_10/Receiver/OrderLifecycleSagaData.cs

@@ -0,0 +1,8 @@
+using System;
+using NServiceBus;
+
+public class OrderLifecycleSagaData :
+    ContainSagaData
+{
+    public virtual Guid OrderId { get; set; }
+}

samples/sqltransport-nhpersistence/Core_10/Receiver/OrderMap.cs

@@ -0,0 +1,13 @@
+using NHibernate.Mapping.ByCode;
+using NHibernate.Mapping.ByCode.Conformist;
+
+class OrderMap :
+    ClassMapping<Order>
+{
+    public OrderMap()
+    {
+        Table("Orders");
+        Id(x => x.OrderId, m => m.Generator(Generators.Assigned));
+        Property(p => p.Value);
+    }
+}

samples/sqltransport-nhpersistence/Core_10/Receiver/OrderSubmittedHandler.cs

@@ -0,0 +1,35 @@
+using System.Threading.Tasks;
+using NServiceBus;
+using Microsoft.Extensions.Logging;
+
+public class OrderSubmittedHandler(ILogger<OrderSubmittedHandler> logger) :
+    IHandleMessages<OrderSubmitted>
+{
+
+    public Task Handle(OrderSubmitted message, IMessageHandlerContext context)
+    {
+        logger.LogInformation("Order {OrderId} worth {Value} submitted", message.OrderId, message.Value);
+
+        #region StoreUserData
+
+        var nhibernateSession = context.SynchronizedStorageSession.Session();
+        var order = new Order
+        {
+            OrderId = message.OrderId,
+            Value = message.Value
+        };
+        nhibernateSession.Save(order);
+
+        #endregion
+
+        #region Reply
+
+        var orderAccepted = new OrderAccepted
+        {
+            OrderId = message.OrderId,
+        };
+        return context.Reply(orderAccepted);
+
+        #endregion
+    }
+}

samples/sqltransport-nhpersistence/Core_10/Receiver/OrderTimeout.cs

@@ -0,0 +1,3 @@
+public class OrderTimeout
+{
+}

samples/sqltransport-nhpersistence/Core_10/Receiver/Program.cs

@@ -0,0 +1,68 @@
+using System;
+using Microsoft.Extensions.Hosting;
+using NHibernate.Cfg;
+using NHibernate.Dialect;
+using NHibernate.Driver;
+using NHibernate.Mapping.ByCode;
+using NHibernate.Tool.hbm2ddl;
+using NServiceBus;
+using NServiceBus.Persistence;
+using NServiceBus.Transport.SqlServer;
+
+Console.Title = "Receiver";
+var builder = Host.CreateApplicationBuilder(args);
+
+// for SqlExpress use Data Source=.\SqlExpress;Initial Catalog=NsbSamplesSqlNHibernate;Integrated Security=True;Max Pool Size=100;Encrypt=false
+var connectionString = @"Server=localhost,1433;Initial Catalog=NsbSamplesSqlNHibernate;User Id=SA;Password=yourStrong(!)Password;Max Pool Size=100;Encrypt=false";
+var hibernateConfig = new Configuration();
+hibernateConfig.DataBaseIntegration(x =>
+{
+    x.ConnectionString = connectionString;
+    x.Dialect<MsSql2012Dialect>();
+    x.Driver<MicrosoftDataSqlClientDriver>();
+});
+
+#region NHibernate
+
+hibernateConfig.SetProperty("default_schema", "receiver");
+
+#endregion
+
+await SqlHelper.CreateSchema(connectionString, "receiver");
+var mapper = new ModelMapper();
+mapper.AddMapping<OrderMap>();
+hibernateConfig.AddMapping(mapper.CompileMappingForAllExplicitlyAddedEntities());
+
+await new SchemaExport(hibernateConfig).ExecuteAsync(false, true, false);
+
+#region ReceiverConfiguration
+
+var endpointConfiguration = new EndpointConfiguration("Samples.SqlNHibernate.Receiver");
+endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+endpointConfiguration.SendFailedMessagesTo("error");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
+endpointConfiguration.EnableInstallers();
+var transport = new SqlServerTransport(connectionString)
+{
+    DefaultSchema = "receiver"
+};
+transport.SchemaAndCatalog.UseSchemaForQueue("error", "dbo");
+transport.SchemaAndCatalog.UseSchemaForQueue("audit", "dbo");
+transport.SchemaAndCatalog.UseSchemaForQueue("Samples.SqlNHibernate.Sender", "sender");
+transport.Subscriptions.SubscriptionTableName = new SubscriptionTableName("Subscriptions", "dbo");
+transport.TransportTransactionMode = TransportTransactionMode.SendsAtomicWithReceive;
+
+var routing = endpointConfiguration.UseTransport(transport);
+routing.RouteToEndpoint(typeof(OrderAccepted), "Samples.SqlNHibernate.Sender");
+
+var persistence = endpointConfiguration.UsePersistence<NHibernatePersistence>();
+persistence.UseConfiguration(hibernateConfig);
+
+#endregion
+
+
+Console.WriteLine("Press any key to exit");
+Console.ReadKey();
+builder.UseNServiceBus(endpointConfiguration);
+
+await builder.Build().RunAsync();

samples/sqltransport-nhpersistence/Core_10/Receiver/Receiver.csproj

@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <OutputType>Exe</OutputType>
+    <LangVersion>preview</LangVersion>
+  </PropertyGroup>
+  <ItemGroup>
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="4.0.0-alpha.2" />
+    <ProjectReference Include="..\Shared\Shared.csproj" />
+    <PackageReference Include="NHibernate" Version="5.*" />
+    <PackageReference Include="NServiceBus.NHibernate" Version="11.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.Transport.SqlServer" Version="9.0.0-alpha.2" />
+  </ItemGroup>
+</Project>

samples/sqltransport-nhpersistence/Core_10/Sender/OrderAcceptedHandler.cs

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

samples/sqltransport-nhpersistence/Core_10/Sender/Program.cs

@@ -0,0 +1,79 @@
+using System;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using NHibernate.Cfg;
+using NHibernate.Dialect;
+using NHibernate.Driver;
+using NServiceBus;
+using NServiceBus.Persistence;
+using NServiceBus.Transport.SqlServer;
+
+var builder = Host.CreateApplicationBuilder(args);
+Console.Title = "Sender";
+
+// for SqlExpress use Data Source=.\SqlExpress;Initial Catalog=NsbSamplesSqlNHibernate;Integrated Security=True;Max Pool Size=100;Encrypt=false
+var connectionString = @"Server=localhost,1433;Initial Catalog=NsbSamplesSqlNHibernate;User Id=SA;Password=yourStrong(!)Password;Max Pool Size=100;Encrypt=false";
+var endpointConfiguration = new EndpointConfiguration("Samples.SqlNHibernate.Sender");
+endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+endpointConfiguration.SendFailedMessagesTo("error");
+endpointConfiguration.EnableInstallers();
+
+var hibernateConfig = new Configuration();
+hibernateConfig.DataBaseIntegration(x =>
+{
+    x.ConnectionString = connectionString;
+    x.Dialect<MsSql2012Dialect>();
+    x.Driver<MicrosoftDataSqlClientDriver>();
+});
+hibernateConfig.SetProperty("default_schema", "sender");
+
+#region SenderConfiguration
+
+var transport = new SqlServerTransport(connectionString)
+{
+    DefaultSchema = "sender",
+    TransportTransactionMode = TransportTransactionMode.SendsAtomicWithReceive
+};
+transport.SchemaAndCatalog.UseSchemaForQueue("error", "dbo");
+transport.SchemaAndCatalog.UseSchemaForQueue("audit", "dbo");
+transport.Subscriptions.SubscriptionTableName = new SubscriptionTableName("Subscriptions", "dbo");
+
+var persistence = endpointConfiguration.UsePersistence<NHibernatePersistence>();
+persistence.UseConfiguration(hibernateConfig);
+
+#endregion
+
+var routing = endpointConfiguration.UseTransport(transport);
+routing.RouteToEndpoint(typeof(OrderAccepted), "Samples.SqlNHibernate.Sender");
+
+await SqlHelper.CreateSchema(connectionString, "sender");
+
+Console.WriteLine("Press enter to send a message");
+Console.WriteLine("Press any key to exit");
+builder.UseNServiceBus(endpointConfiguration);
+
+var host = builder.Build();
+await host.StartAsync();
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+while (true)
+{
+    var key = Console.ReadKey();
+    Console.WriteLine();
+
+    if (key.Key != ConsoleKey.Enter)
+    {
+        break;
+    }
+
+    var orderSubmitted = new OrderSubmitted
+    {
+        OrderId = Guid.NewGuid(),
+        Value = Random.Shared.Next(100)
+    };
+
+    await messageSession.Publish(orderSubmitted);
+
+    Console.WriteLine("Published OrderSubmitted message");
+}