Skip to content

Commit fab320d

Browse files
committed
Remove messaging header normalization
1 parent 91a0730 commit fab320d

File tree

3 files changed

+4
-4
lines changed
  • instrumentation

3 files changed

+4
-4
lines changed

instrumentation/kafka/kafka-clients/kafka-clients-2.6/library/src/test/java/io/opentelemetry/instrumentation/kafkaclients/v2_6/InterceptorsTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ void assertTraces() {
4848
.hasParent(trace.getSpan(0))
4949
.hasAttributesSatisfyingExactly(
5050
equalTo(
51-
stringArrayKey("messaging.header.Test-Message-Header"),
51+
headerAttributeKey(),
5252
singletonList("test")),
5353
equalTo(MESSAGING_SYSTEM, "kafka"),
5454
equalTo(MESSAGING_DESTINATION_NAME, SHARED_TOPIC),
@@ -117,7 +117,7 @@ void assertTraces() {
117117

118118
private AttributeKey<List<String>> headerAttributeKey() {
119119
if (SemconvStability.isEmitOldMessageSemconv()) {
120-
return AttributeKey.stringArrayKey("messaging.header.Test_MessageHeader");
120+
return AttributeKey.stringArrayKey("messaging.header.Test_Message_Header");
121121
} else {
122122
return AttributeKey.stringArrayKey("messaging.header.Test-Message-Header");
123123
}

instrumentation/rocketmq/rocketmq-client/rocketmq-client-4.8/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclient/v4_8/AbstractRocketMqClientTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,7 @@ private static Consumer<List<? extends LinkData>> links(SpanContext... spanConte
460460

461461
private AttributeKey<List<String>> headerAttributeKey() {
462462
if (SemconvStability.isEmitOldMessageSemconv()) {
463-
return AttributeKey.stringArrayKey("messaging.header.Test_MessageHeader");
463+
return AttributeKey.stringArrayKey("messaging.header.Test_Message_Header");
464464
} else {
465465
return AttributeKey.stringArrayKey("messaging.header.Test-Message-Header");
466466
}

instrumentation/rocketmq/rocketmq-client/rocketmq-client-5.0/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclient/v5_0/AbstractRocketMqClientTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -603,7 +603,7 @@ private static SpanDataAssert assertProcessSpanWithDelayMessage(
603603

604604
private AttributeKey<List<String>> headerAttributeKey() {
605605
if (SemconvStability.isEmitOldMessageSemconv()) {
606-
return AttributeKey.stringArrayKey("messaging.header.Test_MessageHeader");
606+
return AttributeKey.stringArrayKey("messaging.header.Test_Message_Header");
607607
} else {
608608
return AttributeKey.stringArrayKey("messaging.header.Test-Message-Header");
609609
}

0 commit comments

Comments
 (0)