Change to use ActivitySource

Author: ejsmith

src/Foundatio.TestHarness/Queue/QueueTestBase.cs

@@ -9,7 +9,6 @@
 using Foundatio.Queues;
 using Foundatio.Tests.Extensions;
 using Foundatio.Utility;
-using Foundatio.Diagnostics;
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
@@ -90,7 +89,14 @@ public virtual async Task CanUseQueueOptionsAsync() {
                 return;
 
             try {
-                QueuesDiagnosticSource.ListenToProcessQueueEntry(o => _logger.LogInformation("OnStart"), o => _logger.LogInformation("OnStop"));
+                using var listener = new ActivityListener {
+                    ShouldListenTo = s => s.Name == "Foundatio",
+                    Sample = (ref ActivityCreationOptions<ActivityContext> _) => ActivitySamplingResult.AllData,
+                    ActivityStarted = activity => _logger.LogInformation("Start: " + activity.DisplayName),
+                    ActivityStopped = activity => _logger.LogInformation("Stop: " + activity.DisplayName)
+                };
+
+                ActivitySource.AddActivityListener(listener);
 
                 await queue.DeleteQueueAsync();
                 await AssertEmptyQueueAsync(queue);

src/Foundatio/Queues/QueueBase.cs

@@ -1,10 +1,9 @@
-using System;
+using System;
 using System.Collections.Generic;
 using System.Diagnostics;
 using System.Linq;
 using System.Threading;
 using System.Threading.Tasks;
-using Foundatio.Diagnostics;
 using Foundatio.Serializer;
 using Foundatio.Utility;
 using Microsoft.Extensions.Logging;
@@ -123,16 +122,15 @@ protected virtual Task OnEnqueuedAsync(IQueueEntry<T> entry) {
         public AsyncEvent<DequeuedEventArgs<T>> Dequeued { get; } = new AsyncEvent<DequeuedEventArgs<T>>(true);
 
         protected virtual void StartProcessQueueEntryActivity(IQueueEntry<T> entry) {
-            if (!QueuesDiagnosticSource.Logger.IsEnabled("ProcessQueueEntry") || !QueuesDiagnosticSource.Logger.IsEnabled("ProcessQueueEntry", entry))
+            var activity = FoundatioDiagnostics.ActivitySource.StartActivity("ProcessQueueEntry", ActivityKind.Internal);
+            if (activity == null)
                 return;
 
-            var activity = new Activity("ProcessQueueEntry");
             activity.AddTag("Id", entry.Id);
             if (!String.IsNullOrEmpty(entry.CorrelationId))
                 activity.SetParentId(entry.CorrelationId);
 
             EnrichProcessQueueEntryActivity(activity, entry);
-            QueuesDiagnosticSource.Logger.StartActivity(activity, entry);
 
             entry.Properties["@Activity"] = activity;
         }
@@ -144,7 +142,7 @@ protected virtual void StopProcessQueueEntryActivity(IQueueEntry<T> entry) {
                 return;
 
             entry.Properties.Remove("@Activity");
-            QueuesDiagnosticSource.Logger.StopActivity(activity, entry);
+            activity.Stop();
         }
 
         protected virtual Task OnDequeuedAsync(IQueueEntry<T> entry) {

src/Foundatio/Utility/DiagnosticActivityListener.cs

@@ -0,0 +1,10 @@
+using System;
+using System.Diagnostics;
+using System.Reflection;
+
+namespace Foundatio {
+    internal static class FoundatioDiagnostics {
+        private static readonly AssemblyName AssemblyName = typeof(FoundatioDiagnostics).Assembly.GetName();
+        internal static readonly ActivitySource ActivitySource = new(AssemblyName.Name, AssemblyName.Version.ToString());
+    }
+}