Updating logging-notification sample to NET 10 (#7462)

Author: irinascurtu

samples/logging/notifications/Core_10/Notifications.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", "{48F718EE-6C45-41BA-80EC-81BF34D4A623}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{48F718EE-6C45-41BA-80EC-81BF34D4A623}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{48F718EE-6C45-41BA-80EC-81BF34D4A623}.Debug|Any CPU.Build.0 = Debug|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+EndGlobal

samples/logging/notifications/Core_10/Sample/MyHandler.cs

@@ -0,0 +1,14 @@
+using System;
+using System.Threading.Tasks;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+public class MyHandler(ILogger<MyHandler> logger) :
+    IHandleMessages<MyMessage>
+{
+    public Task Handle(MyMessage message, IMessageHandlerContext context)
+    {
+        logger.LogCritical("Received message with property: {Property}", message.Property);
+        throw new Exception("The exception message");
+    }
+}

samples/logging/notifications/Core_10/Sample/MyMessage.cs

@@ -0,0 +1,7 @@
+using NServiceBus;
+
+public class MyMessage :
+    IMessage
+{
+    public string Property { get; set; }
+}

samples/logging/notifications/Core_10/Sample/Program.cs

@@ -0,0 +1,57 @@
+using System;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.Logging;
+using NServiceBus;
+
+
+var host = Host.CreateDefaultBuilder(args)
+    .ConfigureServices((hostContext, services) =>
+    {
+        #region logging
+        services.AddLogging(x =>
+        {
+            x.SetMinimumLevel(LogLevel.Critical);
+        });
+        #endregion
+
+    })
+    .UseConsoleLifetime()
+    .UseNServiceBus(context =>
+    {
+        #region endpointConfig
+
+        var endpointConfiguration = new EndpointConfiguration("Samples.Notifications");
+        SubscribeToNotifications.Subscribe(endpointConfiguration);
+        #endregion
+
+        endpointConfiguration.UsePersistence<LearningPersistence>();
+        endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+        endpointConfiguration.UseTransport(new LearningTransport());
+       
+        #region customDelayedRetries
+
+        var recoverability = endpointConfiguration.Recoverability();
+        recoverability.Delayed(
+            customizations: delayed =>
+            {
+                delayed.TimeIncrease(TimeSpan.FromSeconds(1));
+            });
+
+        #endregion
+
+        return endpointConfiguration;
+    }).Build();
+
+
+var messageSession = host.Services.GetRequiredService<IMessageSession>();
+
+var message = new MyMessage
+{
+    Property = "PropertyValue"
+};
+
+await messageSession.SendLocal(message);
+
+Console.WriteLine("Press Ctrl+C to exit");
+await host.RunAsync();

samples/logging/notifications/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/logging/notifications/Core_10/Sample/SubscribeToNotifications.cs

@@ -0,0 +1,55 @@
+using System;
+using System.Text;
+using System.Threading;
+using System.Threading.Tasks;
+using NServiceBus;
+using NServiceBus.Faults;
+using NServiceBus.Logging;
+
+#region subscriptions
+
+public static class SubscribeToNotifications
+{
+    static ILog log = LogManager.GetLogger(typeof(SubscribeToNotifications));
+
+    public static void Subscribe(EndpointConfiguration endpointConfiguration)
+    {
+        var recoverability = endpointConfiguration.Recoverability();
+        recoverability.Immediate(settings => settings.OnMessageBeingRetried(Log));
+        recoverability.Delayed(settings => settings.OnMessageBeingRetried(Log));
+        recoverability.Failed(settings => settings.OnMessageSentToErrorQueue(Log));
+    }
+
+    static string GetMessageString(ReadOnlyMemory<byte> body)
+    {
+        return Encoding.UTF8.GetString(body.ToArray());
+    }
+
+    static Task Log(FailedMessage failed, CancellationToken cancellationToken)
+    {
+        log.Fatal($@"Message sent to error queue.
+        Body:
+        {GetMessageString(failed.Body)}");
+        return Task.CompletedTask;
+    }
+
+    static Task Log(DelayedRetryMessage retry, CancellationToken cancellationToken)
+    {
+        log.Fatal($@"Message sent to Delayed Retries.
+        RetryAttempt:{retry.RetryAttempt}
+        Body:
+        {GetMessageString(retry.Body)}");
+        return Task.CompletedTask;
+    }
+
+    static Task Log(ImmediateRetryMessage retry, CancellationToken cancellationToken)
+    {
+        log.Fatal($@"Message sent to Immediate Retry.
+        RetryAttempt:{retry.RetryAttempt}
+        Body:
+        {GetMessageString(retry.Body)}");
+        return Task.CompletedTask;
+    }
+}
+
+#endregion

samples/logging/notifications/Core_10/prerelease.txt

@@ -20,7 +20,7 @@ This sample uses several non-standard settings.
 
 ### Logging
 
-All errors below Fatal are suppressed to reduce the noise related to raising multiple exceptions
+All errors below Critical are suppressed to reduce the noise related to raising multiple exceptions
 
 snippet: logging