Maybe I am mistaken, but it seems the mp.messaging.[incoming/outgoing].*.tracing.attribute-headers does not work anymore?
I tried setting it in an example application, the custom header is also present in the internally created RabbitMQTrace but its not set in the OpenTelemetry span.
In the codebase I also can't find any usage of RabbitMQConnectorCommonConfiguration.getTracingAttributeHeaders() anywhere.
It was used in First commit of rabbitmq connector (b1e6ad8) but all usages have later been removed by Use OpenTelemetry Instrumenter (2d48857)
I guess it should be used here?
|
public void onStart( |
|
final AttributesBuilder attributes, |
|
final Context parentContext, final RabbitMQTrace rabbitMQTrace) { |
|
attributes.put(MESSAGING_RABBITMQ_DESTINATION_ROUTING_KEY, rabbitMQTrace.getRoutingKey()); |
|
} |
Maybe I am mistaken, but it seems the
mp.messaging.[incoming/outgoing].*.tracing.attribute-headersdoes not work anymore?I tried setting it in an example application, the custom header is also present in the internally created
RabbitMQTracebut its not set in the OpenTelemetry span.In the codebase I also can't find any usage of
RabbitMQConnectorCommonConfiguration.getTracingAttributeHeaders()anywhere.It was used in First commit of rabbitmq connector (b1e6ad8) but all usages have later been removed by Use OpenTelemetry Instrumenter (2d48857)
I guess it should be used here?
smallrye-reactive-messaging/smallrye-reactive-messaging-rabbitmq/src/main/java/io/smallrye/reactive/messaging/rabbitmq/tracing/RabbitMQTraceAttributesExtractor.java
Lines 25 to 29 in 5db863e