This repository was archived by the owner on Oct 31, 2024. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +4
-3
lines changed
packages/plugin-aws-sdk/src/services Expand file tree Collapse file tree 1 file changed +4
-3
lines changed Original file line number Diff line number Diff line change @@ -89,7 +89,7 @@ export class SqsServiceExtension implements ServiceExtension {
8989 {
9090 isIncoming = true ;
9191 spanKind = SpanKind . CONSUMER ;
92- spanName = queueName ;
92+ spanName = ` ${ queueName } receive` ;
9393 spanAttributes [ SqsAttributeNames . MESSAGING_OPERATION ] = "receive" ;
9494
9595 const params : Record < string , any > = ( request as any ) . params ;
@@ -102,7 +102,7 @@ export class SqsServiceExtension implements ServiceExtension {
102102 case "sendMessage" :
103103 case "sendMessageBatch" :
104104 spanKind = SpanKind . PRODUCER ;
105- spanName = queueName ;
105+ spanName = ` ${ queueName } send` ;
106106 break ;
107107 }
108108
@@ -200,7 +200,8 @@ export class SqsServiceExtension implements ServiceExtension {
200200 } as Link ) ;
201201 }
202202
203- const messageSpan = this . tracer . startSpan ( queueName , {
203+ const spanName = `${ queueName } process` ;
204+ const messageSpan = this . tracer . startSpan ( spanName , {
204205 kind : SpanKind . CONSUMER ,
205206 attributes : {
206207 [ SqsAttributeNames . MESSAGING_SYSTEM ] : "aws.sqs" ,
You can’t perform that action at this time.
0 commit comments