diff --git a/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/MapSetter.java b/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/MapSetter.java index 509a6b1fd818..13e7d03c1898 100644 --- a/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/MapSetter.java +++ b/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/MapSetter.java @@ -14,7 +14,7 @@ enum MapSetter implements TextMapSetter { @Override public void set(@Nullable PublishingMessageImpl carrier, String key, String value) { - if (null == carrier || !"traceparent".equals(key)) { + if (null == carrier) { return; } carrier.setTraceContext(value);