@@ -15,7 +15,7 @@ public static class RabbitMQActivitySource
1515 // https://opentelemetry.io/docs/specs/semconv/messaging/messaging-spans/#messaging-attributes
1616 internal const string MessageId = "messaging.message.id" ;
1717 internal const string MessageConversationId = "messaging.message.conversation_id" ;
18- internal const string MessagingOperation = "messaging.operation" ;
18+ internal const string MessagingOperationType = "messaging.operation.type " ;
1919 internal const string MessagingSystem = "messaging.system" ;
2020 internal const string MessagingDestination = "messaging.destination.name" ;
2121 internal const string MessagingDestinationRoutingKey = "messaging.rabbitmq.destination.routing_key" ;
@@ -90,7 +90,7 @@ public static class RabbitMQActivitySource
9090 if ( activity != null && activity . IsAllDataRequested )
9191 {
9292 activity
93- . SetTag ( MessagingOperation , "receive" )
93+ . SetTag ( MessagingOperationType , "receive" )
9494 . SetTag ( MessagingDestination , "amq.default" ) ;
9595 }
9696
@@ -174,7 +174,7 @@ private static void PopulateMessagingTags(string operation, string routingKey, s
174174 ulong deliveryTag , int bodySize , Activity activity )
175175 {
176176 activity
177- . SetTag ( MessagingOperation , operation )
177+ . SetTag ( MessagingOperationType , operation )
178178 . SetTag ( MessagingDestination , string . IsNullOrEmpty ( exchange ) ? "amq.default" : exchange )
179179 . SetTag ( MessagingDestinationRoutingKey , routingKey )
180180 . SetTag ( MessagingBodySize , bodySize ) ;
0 commit comments