Skip to content

Commit 381b29d

Browse files
author
Isaiah Inuwa
committed
Update span operation names to comply with OTel semantic conventions
1 parent efe9862 commit 381b29d

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

projects/RabbitMQ.Client/Impl/RabbitMQActivitySource.cs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -63,14 +63,14 @@ public static class RabbitMQActivitySource
6363

6464
Activity? activity = linkedContext == default
6565
? s_publisherSource.StartRabbitMQActivity(
66-
UseRoutingKeyAsOperationName ? $"{routingKey} publish" : "publish",
66+
UseRoutingKeyAsOperationName ? $"{routingKey} send" : "send",
6767
ActivityKind.Producer)
6868
: s_publisherSource.StartLinkedRabbitMQActivity(
69-
UseRoutingKeyAsOperationName ? $"{routingKey} publish" : "publish",
69+
UseRoutingKeyAsOperationName ? $"{routingKey} send" : "send",
7070
ActivityKind.Producer, linkedContext);
7171
if (activity != null && activity.IsAllDataRequested)
7272
{
73-
PopulateMessagingTags("publish", routingKey, exchange, 0, bodySize, activity);
73+
PopulateMessagingTags("send", routingKey, exchange, 0, bodySize, activity);
7474
}
7575

7676
return activity;
@@ -128,11 +128,11 @@ public static class RabbitMQActivitySource
128128

129129
// Extract the PropagationContext of the upstream parent from the message headers.
130130
Activity? activity = s_subscriberSource.StartLinkedRabbitMQActivity(
131-
UseRoutingKeyAsOperationName ? $"{routingKey} deliver" : "deliver",
131+
UseRoutingKeyAsOperationName ? $"{routingKey} process" : "process",
132132
ActivityKind.Consumer, ContextExtractor(basicProperties));
133133
if (activity != null && activity.IsAllDataRequested)
134134
{
135-
PopulateMessagingTags("deliver", routingKey, exchange,
135+
PopulateMessagingTags("process", routingKey, exchange,
136136
deliveryTag, basicProperties, bodySize, activity);
137137
}
138138

0 commit comments

Comments
 (0)