diff --git a/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/RocketMqInstrumenterFactory.java b/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/RocketMqInstrumenterFactory.java index cb9719cc962c..a77068399890 100644 --- a/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/RocketMqInstrumenterFactory.java +++ b/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/javaagent/src/main/java/io/opentelemetry/javaagent/instrumentation/rocketmqclientjava/v5_0/RocketMqInstrumenterFactory.java @@ -5,9 +5,6 @@ package io.opentelemetry.javaagent.instrumentation.rocketmqclientjava.v5_0; -import static io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor.constant; -import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_OPERATION; - import io.opentelemetry.api.OpenTelemetry; import io.opentelemetry.api.trace.StatusCode; import io.opentelemetry.instrumentation.api.instrumenter.AttributesExtractor; @@ -43,7 +40,6 @@ public static Instrumenter createProduce MessagingSpanNameExtractor.create(getter, operation)) .addAttributesExtractor(attributesExtractor) .addAttributesExtractor(RocketMqProducerAttributeExtractor.INSTANCE) - .addAttributesExtractor(constant(MESSAGING_OPERATION, "send")) .setSpanStatusExtractor( (spanStatusBuilder, message, sendReceipt, error) -> { if (null != error) { diff --git a/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclientjava/v5_0/AbstractRocketMqClientTest.java b/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclientjava/v5_0/AbstractRocketMqClientTest.java index e6d8b112d8ea..e1e1d554e908 100644 --- a/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclientjava/v5_0/AbstractRocketMqClientTest.java +++ b/instrumentation/rocketmq/rocketmq-client-java/rocketmq-client-java-5.0/testing/src/main/java/io/opentelemetry/instrumentation/rocketmqclientjava/v5_0/AbstractRocketMqClientTest.java @@ -9,7 +9,6 @@ import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_DESTINATION_KIND; import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_MESSAGE_ID; import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_MESSAGE_PAYLOAD_SIZE_BYTES; -import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_OPERATION; import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_ROCKETMQ_MESSAGE_KEYS; import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_ROCKETMQ_MESSAGE_TAG; import static io.opentelemetry.semconv.trace.attributes.SemanticAttributes.MESSAGING_ROCKETMQ_MESSAGE_TYPE; @@ -95,7 +94,6 @@ public void testSendMessage() throws ClientException { .hasAttribute( MESSAGING_MESSAGE_PAYLOAD_SIZE_BYTES, (long) body.length) .hasAttribute(MESSAGING_SYSTEM, "rocketmq") - .hasAttribute(MESSAGING_OPERATION, "send") .hasAttribute( MESSAGING_MESSAGE_ID, sendReceipt.getMessageId().toString()) .hasStatus(StatusData.unset())