Set type to queue message (#36397)

Azure · May 26, 2023 · 8a0a766 · 8a0a766
1 parent f4184e4
commit 8a0a766
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 1 deletion.
diff --git a/...or/Azure.Monitor.OpenTelemetry.Exporter/src/Customizations/Models/RemoteDependencyData.cs b/...or/Azure.Monitor.OpenTelemetry.Exporter/src/Customizations/Models/RemoteDependencyData.cs
@@ -83,6 +83,10 @@ public RemoteDependencyData(int version, Activity activity, ref ActivityTagsProc
                 {
                     Type = $"InProc | {activityTagsProcessor.MappedTags.GetAzNameSpace()}";
                 }
+                else if (activity.Kind == ActivityKind.Producer)
+                {
+                    Type = $"Queue Message | {activityTagsProcessor.MappedTags.GetAzNameSpace()}";
+                }
                 else
                 {
                     // The Azure SDK sets az.namespace with its resource provider information.

diff --git a/...ry.Exporter/tests/Azure.Monitor.OpenTelemetry.Exporter.Tests/RemoteDependencyDataTests.cs b/...ry.Exporter/tests/Azure.Monitor.OpenTelemetry.Exporter.Tests/RemoteDependencyDataTests.cs
@@ -87,7 +87,18 @@ public void RemoteDependencyTypeReflectsAzureNamespace(ActivityKind activityKind
             var remoteDependencyData = new RemoteDependencyData(2, activity, ref activityTagsProcessor);
 
             Assert.True(activityTagsProcessor.HasAzureNamespace);
-            Assert.Equal(activity.Kind == ActivityKind.Internal ? "InProc | DemoAzureResource" : "DemoAzureResource", remoteDependencyData.Type);
+            if (activity.Kind == ActivityKind.Internal)
+            {
+                Assert.Equal("InProc | DemoAzureResource", remoteDependencyData.Type);
+            }
+            else if (activity.Kind == ActivityKind.Producer)
+            {
+                Assert.Equal("Queue Message | DemoAzureResource", remoteDependencyData.Type);
+            }
+            else
+            {
+                Assert.Equal("DemoAzureResource", remoteDependencyData.Type);
+            }
         }
 
         [Fact]