Skip to content

Commit 475aca8

Browse files
Add new otel attribute for Rabbitmq backend (#447)
* Add new otel attribute for Rabitmq backend * Increase vuln expiry
1 parent 4fa3a54 commit 475aca8

File tree

2 files changed

+7
-1
lines changed

2 files changed

+7
-1
lines changed

semantic-convention-utils/src/main/java/org/hypertrace/semantic/convention/utils/messaging/MessagingSemanticConventionUtils.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,8 @@ public class MessagingSemanticConventionUtils {
5050
new ArrayList<>(
5151
Arrays.asList(
5252
RawSpanConstants.getValue(RabbitMq.RABBIT_MQ_ROUTING_KEY),
53-
OtelMessagingSemanticConventions.RABBITMQ_ROUTING_KEY.getValue()));
53+
OtelMessagingSemanticConventions.RABBITMQ_ROUTING_KEY.getValue(),
54+
OtelMessagingSemanticConventions.RABBITMQ_DESTINATION_ROUTING_KEY.getValue()));
5455

5556
/**
5657
* @param event Object encapsulating span data

span-normalizer/span-normalizer-constants/src/main/java/org/hypertrace/core/semantic/convention/constants/messaging/OtelMessagingSemanticConventions.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,12 @@ public enum OtelMessagingSemanticConventions {
55
MESSAGING_SYSTEM("messaging.system"),
66
MESSAGING_URL("messaging.url"),
77
RABBITMQ_MESSAGING_SYSTEM_VALUE("rabbitmq"),
8+
/**
9+
* Otel semantic-conventions-java has marked this @deprecated. Use {@link
10+
* OtelMessagingSemanticConventions#RABBITMQ_DESTINATION_ROUTING_KEY} instead
11+
*/
812
RABBITMQ_ROUTING_KEY("messaging.rabbitmq.routing_key"),
13+
RABBITMQ_DESTINATION_ROUTING_KEY("messaging.rabbitmq.destination.routing_key"),
914
RABBITMQ_COMMAND("rabbitmq.command"),
1015
KAFKA_MESSAGING_SYSTEM_VALUE("kafka"),
1116
AWS_SQS_MESSAGING_SYSTEM_VALUE("sqs"),

0 commit comments

Comments
 (0)