@@ -63,14 +63,14 @@ public static class RabbitMQActivitySource
63
63
64
64
Activity ? activity = linkedContext == default
65
65
? s_publisherSource . StartRabbitMQActivity (
66
- UseRoutingKeyAsOperationName ? $ "{ routingKey } publish " : "publish " ,
66
+ UseRoutingKeyAsOperationName ? $ "{ routingKey } send " : "send " ,
67
67
ActivityKind . Producer )
68
68
: s_publisherSource . StartLinkedRabbitMQActivity (
69
- UseRoutingKeyAsOperationName ? $ "{ routingKey } publish " : "publish " ,
69
+ UseRoutingKeyAsOperationName ? $ "{ routingKey } send " : "send " ,
70
70
ActivityKind . Producer , linkedContext ) ;
71
71
if ( activity != null && activity . IsAllDataRequested )
72
72
{
73
- PopulateMessagingTags ( "publish " , routingKey , exchange , 0 , bodySize , activity ) ;
73
+ PopulateMessagingTags ( "send " , routingKey , exchange , 0 , bodySize , activity ) ;
74
74
}
75
75
76
76
return activity ;
@@ -128,11 +128,11 @@ public static class RabbitMQActivitySource
128
128
129
129
// Extract the PropagationContext of the upstream parent from the message headers.
130
130
Activity ? activity = s_subscriberSource . StartLinkedRabbitMQActivity (
131
- UseRoutingKeyAsOperationName ? $ "{ routingKey } deliver " : "deliver " ,
131
+ UseRoutingKeyAsOperationName ? $ "{ routingKey } process " : "process " ,
132
132
ActivityKind . Consumer , ContextExtractor ( basicProperties ) ) ;
133
133
if ( activity != null && activity . IsAllDataRequested )
134
134
{
135
- PopulateMessagingTags ( "deliver " , routingKey , exchange ,
135
+ PopulateMessagingTags ( "process " , routingKey , exchange ,
136
136
deliveryTag , basicProperties , bodySize , activity ) ;
137
137
}
138
138
0 commit comments