Skip to content

Commit a02f88e

Browse files
committed
Remove messaging header normalization
1 parent ced3f5d commit a02f88e

File tree

1 file changed

+12
-4
lines changed

1 file changed

+12
-4
lines changed

instrumentation/aws-sdk/aws-sdk-2.2/testing/src/main/java/io/opentelemetry/instrumentation/awssdk/v2_2/AbstractAws2SqsTracingTest.java

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -216,10 +216,18 @@ protected void assertSqsTraces(boolean withParent, boolean captureHeaders) {
216216
MESSAGING_MESSAGE_ID, v -> v.isInstanceOf(String.class))));
217217

218218
if (captureHeaders) {
219-
attributes.add(
220-
satisfies(
221-
stringArrayKey("messaging.header.Test-Message-Header"),
222-
v -> v.isEqualTo(singletonList("test"))));
219+
if (SemconvStability.isEmitOldMessageSemconv()) {
220+
attributes.add(
221+
satisfies(
222+
stringKey("messaging.header.Test_Message_Header"),
223+
v -> v.isEqualTo("test")));
224+
}
225+
if (SemconvStability.isEmitStableMessageSemconv()) {
226+
attributes.add(
227+
satisfies(
228+
stringArrayKey("messaging.header.Test-Message-Header"),
229+
v -> v.isEqualTo(singletonList("test"))));
230+
}
223231
}
224232

225233
span.hasName("testSdkSqs process")

0 commit comments

Comments
 (0)