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

switch back to messaging.client_id, it is renamed to messaging.client.id in semconv

This commit is contained in:
Lauri Tulmin 2025-09-17 16:53:02 +03:00
parent 043c8575c8
commit e599182a57
No known key found for this signature in database
GPG Key ID: FD1C4A546B329375
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
instrumentation/nats/nats-2.17/testing/src/main/java/io/opentelemetry/instrumentation/nats/v2_17/NatsTestHelper.java
View File

@ -5,8 +5,8 @@
package io.opentelemetry.instrumentation.nats.v2_17;
import static io.opentelemetry.api.common.AttributeKey.stringKey;
import static io.opentelemetry.sdk.testing.assertj.OpenTelemetryAssertions.equalTo;
import static io.opentelemetry.semconv.incubating.MessagingIncubatingAttributes.MESSAGING_CLIENT_ID;
import static io.opentelemetry.semconv.incubating.MessagingIncubatingAttributes.MESSAGING_DESTINATION_NAME;
import static io.opentelemetry.semconv.incubating.MessagingIncubatingAttributes.MESSAGING_MESSAGE_BODY_SIZE;
import static io.opentelemetry.semconv.incubating.MessagingIncubatingAttributes.MESSAGING_OPERATION;
@ -15,12 +15,16 @@ import static org.assertj.core.api.Assertions.assertThat;
import io.nats.client.Message;
import io.nats.client.Subscription;
import io.opentelemetry.api.common.AttributeKey;
import io.opentelemetry.sdk.testing.assertj.AttributeAssertion;
import java.time.Duration;
@SuppressWarnings("deprecation") // using deprecated semconv
public class NatsTestHelper {
// copied from MessagingIncubatingAttributes
private static final AttributeKey<String> MESSAGING_CLIENT_ID = stringKey("messaging.client_id");
public static AttributeAssertion[] messagingAttributes(
String operation, String subject, int clientId, AttributeAssertion other) {
return messagingAttributes(operation, subject, clientId, new AttributeAssertion[] {other});