@@ -15,7 +15,7 @@ public static class RabbitMQActivitySource
15
15
// https://opentelemetry.io/docs/specs/semconv/messaging/messaging-spans/#messaging-attributes
16
16
internal const string MessageId = "messaging.message.id" ;
17
17
internal const string MessageConversationId = "messaging.message.conversation_id" ;
18
- internal const string MessagingOperation = "messaging.operation" ;
18
+ internal const string MessagingOperationType = "messaging.operation.type " ;
19
19
internal const string MessagingSystem = "messaging.system" ;
20
20
internal const string MessagingDestination = "messaging.destination.name" ;
21
21
internal const string MessagingDestinationRoutingKey = "messaging.rabbitmq.destination.routing_key" ;
@@ -90,7 +90,7 @@ public static class RabbitMQActivitySource
90
90
if ( activity != null && activity . IsAllDataRequested )
91
91
{
92
92
activity
93
- . SetTag ( MessagingOperation , "receive" )
93
+ . SetTag ( MessagingOperationType , "receive" )
94
94
. SetTag ( MessagingDestination , "amq.default" ) ;
95
95
}
96
96
@@ -174,7 +174,7 @@ private static void PopulateMessagingTags(string operation, string routingKey, s
174
174
ulong deliveryTag , int bodySize , Activity activity )
175
175
{
176
176
activity
177
- . SetTag ( MessagingOperation , operation )
177
+ . SetTag ( MessagingOperationType , operation )
178
178
. SetTag ( MessagingDestination , string . IsNullOrEmpty ( exchange ) ? "amq.default" : exchange )
179
179
. SetTag ( MessagingDestinationRoutingKey , routingKey )
180
180
. SetTag ( MessagingBodySize , bodySize ) ;
0 commit comments