open-telemetry
/
opentelemetry-java-instrumentation
mirror of https://github.com/open-telemetry/opentelemetry-java-instrumentation.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Replace `"messaging.operation"` with the constant (#1457)

This commit is contained in:
Vadim Shaigorodskiy 2020-10-23 18:54:33 +02:00 committed by GitHub
parent b683a6c417
commit 96eb67de6f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
instrumentation-api/src/main/java/io/opentelemetry/instrumentation/api/typedspan/MessagingConsumerSpan.java
View File

@ -8,6 +8,7 @@ package io.opentelemetry.instrumentation.api.typedspan;
import io.grpc.Context;
import io.opentelemetry.trace.Span;
import io.opentelemetry.trace.Tracer;
import io.opentelemetry.trace.attributes.SemanticAttributes;
public class MessagingConsumerSpan extends DelegatingSpan
implements MessagingConsumerSemanticConvention {
@ -273,7 +274,7 @@ public class MessagingConsumerSpan extends DelegatingSpan
*/
@Override
public MessagingConsumerSemanticConvention setMessagingOperation(String messagingOperation) {
delegate.setAttribute("messaging.operation", messagingOperation);
delegate.setAttribute(SemanticAttributes.MESSAGING_OPERATION, messagingOperation);
return this;
}
@ -515,7 +516,7 @@ public class MessagingConsumerSpan extends DelegatingSpan
* this span describes.
*/
public MessagingConsumerSpanBuilder setMessagingOperation(String messagingOperation) {
internalBuilder.setAttribute("messaging.operation", messagingOperation);
internalBuilder.setAttribute(SemanticAttributes.MESSAGING_OPERATION, messagingOperation);
return this;
}
}

5
instrumentation-api/src/main/java/io/opentelemetry/instrumentation/api/typedspan/MessagingConsumerSynchronousSpan.java
View File

@ -8,6 +8,7 @@ package io.opentelemetry.instrumentation.api.typedspan;
import io.grpc.Context;
import io.opentelemetry.trace.Span;
import io.opentelemetry.trace.Tracer;
import io.opentelemetry.trace.attributes.SemanticAttributes;
public class MessagingConsumerSynchronousSpan extends DelegatingSpan
implements MessagingConsumerSynchronousSemanticConvention {
@ -280,7 +281,7 @@ public class MessagingConsumerSynchronousSpan extends DelegatingSpan
@Override
public MessagingConsumerSynchronousSemanticConvention setMessagingOperation(
String messagingOperation) {
delegate.setAttribute("messaging.operation", messagingOperation);
delegate.setAttribute(SemanticAttributes.MESSAGING_OPERATION, messagingOperation);
return this;
}
@ -526,7 +527,7 @@ public class MessagingConsumerSynchronousSpan extends DelegatingSpan
*/
public MessagingConsumerSynchronousSpanBuilder setMessagingOperation(
String messagingOperation) {
internalBuilder.setAttribute("messaging.operation", messagingOperation);
internalBuilder.setAttribute(SemanticAttributes.MESSAGING_OPERATION, messagingOperation);
return this;
}
}