Merge pull request #7586 from Particular/nsb10-logging-metrics

Add Metrics Logging sample for NServiceBus 10

Author: hsvotwa

samples/logging/metrics/Metrics_6/Endpoint/Endpoint.csproj

@@ -0,0 +1,12 @@
+<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.Metrics" Version="6.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.Extensions.Hosting" Version="4.0.0-alpha.1" />
+  </ItemGroup>
+</Project>

samples/logging/metrics/Metrics_6/Endpoint/Program.cs

@@ -0,0 +1,73 @@
+using System;
+using System.Diagnostics;
+using NServiceBus;
+using Microsoft.Extensions.Hosting;
+using Microsoft.Extensions.DependencyInjection;
+
+Console.Title = "TracingEndpoint";
+
+var host = Host.CreateDefaultBuilder(args)
+    .UseConsoleLifetime()
+    .UseNServiceBus(_ =>
+    {
+        var endpointConfiguration = new EndpointConfiguration("Samples.Metrics.Tracing.Endpoint");
+
+        endpointConfiguration.UseSerialization<SystemJsonSerializer>();
+        endpointConfiguration.UseTransport<LearningTransport>();
+
+        #region EnableMetricTracing
+
+        var metrics = endpointConfiguration.EnableMetrics();
+        metrics.RegisterObservers(
+            register: context =>
+            {
+                foreach (var duration in context.Durations)
+                {
+                    duration.Register(
+                        observer: (ref DurationEvent @event) =>
+                        {
+                            Trace.WriteLine(
+                                $"Duration: '{duration.Name}'. Value: '{@event.Duration}' ({@event.MessageType})");
+                        });
+                }
+
+                foreach (var signal in context.Signals)
+                {
+                    signal.Register(
+                        observer: (ref SignalEvent @event) =>
+                        {
+                            Trace.WriteLine($"Signal: '{signal.Name}' ({@event.MessageType})");
+                        });
+                }
+            });
+
+        #endregion
+
+        return endpointConfiguration;
+    })
+    .Build();
+
+await host.StartAsync();
+
+var endpointInstance = host.Services.GetRequiredService<IMessageSession>();
+
+try
+{
+    Console.WriteLine("Endpoint started. Press 'enter' to send a message");
+    Console.WriteLine("Press any other key to quit");
+
+    while (true)
+    {
+        var key = Console.ReadKey(true);
+        if (key.Key != ConsoleKey.Enter)
+        {
+            break;
+        }
+
+        await endpointInstance.SendLocal(new SomeCommand());
+    }
+}
+finally
+{
+    await host.StopAsync();
+}

samples/logging/metrics/Metrics_6/Endpoint/SomeCommand.cs

@@ -0,0 +1,3 @@
+using NServiceBus;
+
+class SomeCommand : ICommand;

samples/logging/metrics/Metrics_6/Endpoint/SomeCommandHandler.cs

@@ -0,0 +1,15 @@
+using System.Threading.Tasks;
+using NServiceBus;
+using NServiceBus.Logging;
+
+class SomeCommandHandler :
+    IHandleMessages<SomeCommand>
+{
+    static ILog log = LogManager.GetLogger<SomeCommandHandler>();
+
+    public Task Handle(SomeCommand message, IMessageHandlerContext context)
+    {
+        log.Info("Hello from SomeCommandHandler");
+        return Task.CompletedTask;
+    }
+}

samples/logging/metrics/Metrics_6/MetricsTracing.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}") = "Endpoint", "Endpoint\Endpoint.csproj", "{FF5BEF96-88BA-470D-975A-4EF710EE2B7A}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{FF5BEF96-88BA-470D-975A-4EF710EE2B7A}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{FF5BEF96-88BA-470D-975A-4EF710EE2B7A}.Debug|Any CPU.Build.0 = Debug|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+EndGlobal