diff --git a/instrumentation/nats/nats-2.17/testing/src/main/java/io/opentelemetry/instrumentation/nats/v2_17/NatsTestHelper.java b/instrumentation/nats/nats-2.17/testing/src/main/java/io/opentelemetry/instrumentation/nats/v2_17/NatsTestHelper.java index 955fcada37..c83880fea4 100644 --- a/instrumentation/nats/nats-2.17/testing/src/main/java/io/opentelemetry/instrumentation/nats/v2_17/NatsTestHelper.java +++ b/instrumentation/nats/nats-2.17/testing/src/main/java/io/opentelemetry/instrumentation/nats/v2_17/NatsTestHelper.java @@ -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 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});