Skip to content

Commit ced3f5d

Browse files
committed
Remove messaging header normalization
1 parent 12ca51d commit ced3f5d

File tree

1 file changed

+12
-4
lines changed

1 file changed

+12
-4
lines changed

instrumentation/aws-sdk/aws-sdk-1.11/testing/src/main/java/io/opentelemetry/instrumentation/awssdk/v1_11/AbstractSqsTracingTest.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -276,10 +276,18 @@ void testSimpleSqsProducerConsumerServicesCaptureHeaders(boolean testCaptureHead
276276
equalTo(NETWORK_PROTOCOL_VERSION, "1.1")));
277277

278278
if (testCaptureHeaders) {
279-
attributes.add(
280-
satisfies(
281-
stringArrayKey("messaging.header.Test-Message-Header"),
282-
val -> val.isEqualTo(singletonList("test"))));
279+
if (SemconvStability.isEmitOldMessageSemconv()) {
280+
attributes.add(
281+
satisfies(
282+
stringArrayKey("messaging.header.Test_Message_Header"),
283+
val -> val.isEqualTo(singletonList("test"))));
284+
}
285+
if (SemconvStability.isEmitStableMessageSemconv()) {
286+
attributes.add(
287+
satisfies(
288+
stringArrayKey("messaging.header.Test-Message-Header"),
289+
val -> val.isEqualTo(singletonList("test"))));
290+
}
283291
}
284292
span.hasName("testSdkSqs process")
285293
.hasKind(SpanKind.CONSUMER)

0 commit comments

Comments
 (0)