Use endpoints logical address to generate performance counters (#4173)

* use endpoints logical address to generate performance counters * rename ctor parameter
Particular · Sep 28, 2016 · fc7ef8e · fc7ef8e
1 parent 12cd213
commit fc7ef8e
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 7 deletions.
diff --git a/src/NServiceBus.Core/Performance/ReceiveStatisticsFeature.cs b/src/NServiceBus.Core/Performance/ReceiveStatisticsFeature.cs
@@ -12,7 +12,8 @@ public ReceiveStatisticsFeature()
 
         protected internal override void Setup(FeatureConfigurationContext context)
         {
-            var performanceDiagnosticsBehavior = new ReceivePerformanceDiagnosticsBehavior(context.Settings.LocalAddress());
+            var logicalAddress = context.Settings.LogicalAddress();
+            var performanceDiagnosticsBehavior = new ReceivePerformanceDiagnosticsBehavior(logicalAddress.EndpointInstance.Endpoint);
 
             context.Pipeline.Register(performanceDiagnosticsBehavior, "Provides various performance counters for receive statistics");
             context.Pipeline.Register("ProcessingStatistics", new ProcessingStatisticsBehavior(), "Collects timing for ProcessingStarted and adds the state to determine ProcessingEnded");

diff --git a/src/NServiceBus.Core/Performance/Statistics/ReceivePerformanceDiagnosticsBehavior.cs b/src/NServiceBus.Core/Performance/Statistics/ReceivePerformanceDiagnosticsBehavior.cs
@@ -8,22 +8,22 @@ namespace NServiceBus
     [SkipWeaving]
     class ReceivePerformanceDiagnosticsBehavior : IBehavior<IIncomingPhysicalMessageContext, IIncomingPhysicalMessageContext>
     {
-        public ReceivePerformanceDiagnosticsBehavior(string transportAddress)
+        public ReceivePerformanceDiagnosticsBehavior(string queueName)
         {
-            this.transportAddress = transportAddress;
+            this.queueName = queueName;
         }
 
         public void Warmup()
         {
             messagesPulledFromQueueCounter = PerformanceCounterHelper.TryToInstantiatePerformanceCounter(
                 "# of msgs pulled from the input queue /sec",
-                transportAddress);
+                queueName);
             successRateCounter = PerformanceCounterHelper.TryToInstantiatePerformanceCounter(
                 "# of msgs successfully processed / sec",
-                transportAddress);
+                queueName);
             failureRateCounter = PerformanceCounterHelper.TryToInstantiatePerformanceCounter(
                 "# of msgs failures / sec",
-                transportAddress);
+                queueName);
         }
 
         public async Task Invoke(IIncomingPhysicalMessageContext context, Func<IIncomingPhysicalMessageContext, Task> next)
@@ -54,6 +54,6 @@ public void Cooldown()
         IPerformanceCounterInstance messagesPulledFromQueueCounter;
         IPerformanceCounterInstance successRateCounter;
 
-        string transportAddress;
+        string queueName;
     }
 }