This is an automated email from the ASF dual-hosted git repository.

jpoth pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 68d5b245b35e99ea08ee96ec397e4190a9800419
Author: John Poth <poth.j...@gmail.com>
AuthorDate: Wed Sep 25 11:51:45 2024 +0200

    CAMEL-21261 - camel-opentelemetry: let's use the context propagators 
defined in the tracer
---
 .../main/java/org/apache/camel/opentelemetry/OpenTelemetryTracer.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/components/camel-opentelemetry/src/main/java/org/apache/camel/opentelemetry/OpenTelemetryTracer.java
 
b/components/camel-opentelemetry/src/main/java/org/apache/camel/opentelemetry/OpenTelemetryTracer.java
index 8df31fe3329..cdf98014a3e 100644
--- 
a/components/camel-opentelemetry/src/main/java/org/apache/camel/opentelemetry/OpenTelemetryTracer.java
+++ 
b/components/camel-opentelemetry/src/main/java/org/apache/camel/opentelemetry/OpenTelemetryTracer.java
@@ -164,7 +164,7 @@ public class OpenTelemetryTracer extends 
org.apache.camel.tracing.Tracer {
             baggage = spanFromExchange.getBaggage();
         } else {
             ExtractAdapter adapter = 
sd.getExtractAdapter(exchange.getIn().getHeaders(), encoding);
-            Context ctx = 
GlobalOpenTelemetry.get().getPropagators().getTextMapPropagator().extract(Context.current(),
 adapter,
+            Context ctx = 
getContextPropagators().getTextMapPropagator().extract(Context.current(), 
adapter,
                     new OpenTelemetryGetter(adapter));
             Span span = Span.fromContext(ctx);
             baggage = Baggage.fromContext(ctx);
@@ -192,7 +192,7 @@ public class OpenTelemetryTracer extends 
org.apache.camel.tracing.Tracer {
         if (spanFromExchange.getBaggage() != null) {
             ctx = ctx.with(spanFromExchange.getBaggage());
         }
-        
GlobalOpenTelemetry.get().getPropagators().getTextMapPropagator().inject(ctx, 
adapter, new OpenTelemetrySetter());
+        getContextPropagators().getTextMapPropagator().inject(ctx, adapter, 
new OpenTelemetrySetter());
     }
 
     @Override

Reply via email to