diff --git a/semantic-convention-utils/src/main/java/org/hypertrace/semantic/convention/utils/messaging/MessagingSemanticConventionUtils.java b/semantic-convention-utils/src/main/java/org/hypertrace/semantic/convention/utils/messaging/MessagingSemanticConventionUtils.java index 59dfb075f..ec72bcf26 100644 --- a/semantic-convention-utils/src/main/java/org/hypertrace/semantic/convention/utils/messaging/MessagingSemanticConventionUtils.java +++ b/semantic-convention-utils/src/main/java/org/hypertrace/semantic/convention/utils/messaging/MessagingSemanticConventionUtils.java @@ -50,7 +50,8 @@ public class MessagingSemanticConventionUtils { new ArrayList<>( Arrays.asList( RawSpanConstants.getValue(RabbitMq.RABBIT_MQ_ROUTING_KEY), - OtelMessagingSemanticConventions.RABBITMQ_ROUTING_KEY.getValue())); + OtelMessagingSemanticConventions.RABBITMQ_ROUTING_KEY.getValue(), + OtelMessagingSemanticConventions.RABBITMQ_DESTINATION_ROUTING_KEY.getValue())); /** * @param event Object encapsulating span data diff --git a/span-normalizer/span-normalizer-constants/src/main/java/org/hypertrace/core/semantic/convention/constants/messaging/OtelMessagingSemanticConventions.java b/span-normalizer/span-normalizer-constants/src/main/java/org/hypertrace/core/semantic/convention/constants/messaging/OtelMessagingSemanticConventions.java index 19357909a..c2f084aa8 100644 --- a/span-normalizer/span-normalizer-constants/src/main/java/org/hypertrace/core/semantic/convention/constants/messaging/OtelMessagingSemanticConventions.java +++ b/span-normalizer/span-normalizer-constants/src/main/java/org/hypertrace/core/semantic/convention/constants/messaging/OtelMessagingSemanticConventions.java @@ -5,7 +5,12 @@ public enum OtelMessagingSemanticConventions { MESSAGING_SYSTEM("messaging.system"), MESSAGING_URL("messaging.url"), RABBITMQ_MESSAGING_SYSTEM_VALUE("rabbitmq"), + /** + * Otel semantic-conventions-java has marked this @deprecated. Use {@link + * OtelMessagingSemanticConventions#RABBITMQ_DESTINATION_ROUTING_KEY} instead + */ RABBITMQ_ROUTING_KEY("messaging.rabbitmq.routing_key"), + RABBITMQ_DESTINATION_ROUTING_KEY("messaging.rabbitmq.destination.routing_key"), RABBITMQ_COMMAND("rabbitmq.command"), KAFKA_MESSAGING_SYSTEM_VALUE("kafka"), AWS_SQS_MESSAGING_SYSTEM_VALUE("sqs"),