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