Clone Core_9

Author: jasontaylordev

samples/open-telemetry/customizing/Core_10/CustomizingTelemetry.sln

@@ -0,0 +1,25 @@
+
+Microsoft Visual Studio Solution File, Format Version 12.00
+# Visual Studio Version 17
+VisualStudioVersion = 17.2.32616.157
+MinimumVisualStudioVersion = 10.0.40219.1
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Sample", "Sample\Sample.csproj", "{D6DAC310-11C3-4B79-B1E4-AB6078A2E214}"
+EndProject
+Global
+	GlobalSection(SolutionConfigurationPlatforms) = preSolution
+		Debug|Any CPU = Debug|Any CPU
+		Release|Any CPU = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(ProjectConfigurationPlatforms) = postSolution
+		{D6DAC310-11C3-4B79-B1E4-AB6078A2E214}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D6DAC310-11C3-4B79-B1E4-AB6078A2E214}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D6DAC310-11C3-4B79-B1E4-AB6078A2E214}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D6DAC310-11C3-4B79-B1E4-AB6078A2E214}.Release|Any CPU.Build.0 = Release|Any CPU
+	EndGlobalSection
+	GlobalSection(SolutionProperties) = preSolution
+		HideSolutionNode = FALSE
+	EndGlobalSection
+	GlobalSection(ExtensibilityGlobals) = postSolution
+		SolutionGuid = {42F58BDA-0C79-41BB-AA96-F03CAF76FB6F}
+	EndGlobalSection
+EndGlobal

samples/open-telemetry/customizing/Core_10/Sample/Behaviors/TraceCustomExceptionInHandlerBehavior.cs

@@ -0,0 +1,29 @@
+using NServiceBus.Pipeline;
+using System;
+using System.Diagnostics;
+using System.Threading.Tasks;
+
+#region add-tags-from-handler-behavior
+
+class TraceCustomExceptionInHandlerBehavior : Behavior<IInvokeHandlerContext>
+{
+    public override async Task Invoke(IInvokeHandlerContext context, Func<Task> next)
+    {
+        try
+        {
+            await next();
+        }
+        catch (MyBusinessException e)
+        {
+            Activity.Current?.AddTag("sample.business-exception.reason", e.ReasonCode);
+            throw;
+        }
+    }
+}
+
+public class MyBusinessException : Exception
+{
+    public int ReasonCode { get; init; }
+}
+
+#endregion

samples/open-telemetry/customizing/Core_10/Sample/Behaviors/TraceOutgoingMessageSizeBehavior.cs

@@ -0,0 +1,17 @@
+using NServiceBus.Pipeline;
+using System;
+using System.Diagnostics;
+using System.Threading.Tasks;
+
+#region add-tags-from-outgoing-behavior
+
+class TraceOutgoingMessageSizeBehavior : Behavior<IOutgoingPhysicalMessageContext>
+{
+    public override Task Invoke(IOutgoingPhysicalMessageContext context, Func<Task> next)
+    {
+        Activity.Current?.AddTag("sample.messaging.body.size", context.Body.Length);
+        return next();
+    }
+}
+
+#endregion

samples/open-telemetry/customizing/Core_10/Sample/CustomActivitySources.cs

@@ -0,0 +1,9 @@
+using System.Diagnostics;
+
+#region custom-activity-source
+static class CustomActivitySources
+{
+    public const string Name = "Sample.ActivitySource";
+    public static readonly ActivitySource Main = new(Name);
+}
+#endregion

samples/open-telemetry/customizing/Core_10/Sample/Handlers/BillOrderHandler.cs

@@ -0,0 +1,12 @@
+using NServiceBus;
+using System;
+using System.Threading.Tasks;
+
+class BillOrderHandler : IHandleMessages<BillOrder>
+{
+    public Task Handle(BillOrder message, IMessageHandlerContext context)
+    {
+        Console.WriteLine($"Order billed {message.OrderId}");
+        return Task.CompletedTask;
+    }
+}

samples/open-telemetry/customizing/Core_10/Sample/Handlers/CreateOrderHandler.cs

@@ -0,0 +1,26 @@
+using NServiceBus;
+using System;
+using System.Threading.Tasks;
+
+class CreateOrderHandler : IHandleMessages<CreateOrder>
+{
+    #region custom-activity-in-handler
+    public async Task Handle(CreateOrder message, IMessageHandlerContext context)
+    {
+        using var activity = CustomActivitySources.Main.StartActivity("Billing Order");
+
+        if (message.SimulateFailure)
+        {
+            throw new MyBusinessException{ ReasonCode = 1};
+        }
+
+        Console.WriteLine($"Billing order {message.OrderId}");
+        activity?.AddTag("sample.billing.system", "paypal");
+        // Calculate order cost
+        await context.SendLocal(new BillOrder { OrderId = message.OrderId });
+
+        Console.WriteLine($"Shipping order {message.OrderId}");
+        await context.SendLocal(new ShipOrder { OrderId = message.OrderId });
+    }
+    #endregion
+}

samples/open-telemetry/customizing/Core_10/Sample/Handlers/ShipOrderHandler.cs

@@ -0,0 +1,17 @@
+using NServiceBus;
+using System;
+using System.Diagnostics;
+using System.Threading.Tasks;
+
+#region add-tags-from-handler
+class ShipOrderHandler : IHandleMessages<ShipOrder>
+{
+    public Task Handle(ShipOrder message, IMessageHandlerContext context)
+    {
+        Console.WriteLine($"Order shipped {message.OrderId}");
+        // Figure out what state we are shipping to
+        Activity.Current?.AddTag("sample.shipping.state", "STATE");
+        return Task.CompletedTask;
+    }
+}
+#endregion

samples/open-telemetry/customizing/Core_10/Sample/Messages/BillOrder.cs

@@ -0,0 +1,7 @@
+using NServiceBus;
+using System;
+
+class BillOrder : IMessage
+{
+    public Guid OrderId { get; set;}
+}

samples/open-telemetry/customizing/Core_10/Sample/Messages/CreateOrder.cs

@@ -0,0 +1,8 @@
+using NServiceBus;
+using System;
+
+class CreateOrder : IMessage
+{
+    public Guid OrderId { get; set; }
+    public bool SimulateFailure { get; set; }
+}

samples/open-telemetry/customizing/Core_10/Sample/Messages/ShipOrder.cs

@@ -0,0 +1,7 @@
+using NServiceBus;
+using System;
+
+class ShipOrder : IMessage
+{
+    public Guid OrderId { get; set;}
+}