Skip to content

Commit fd91a46

Browse files
Polish
1 parent 7cd8f97 commit fd91a46

File tree

3 files changed

+8
-15
lines changed

3 files changed

+8
-15
lines changed

spring-cloud-sleuth-otel/src/main/java/org/springframework/cloud/sleuth/otel/bridge/OtelPropagator.java

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121

2222
import io.opentelemetry.api.trace.Tracer;
2323
import io.opentelemetry.context.Context;
24-
import io.opentelemetry.context.Scope;
2524
import io.opentelemetry.context.propagation.ContextPropagators;
2625
import io.opentelemetry.context.propagation.TextMapGetter;
2726
import io.opentelemetry.context.propagation.TextMapPropagator;
@@ -74,10 +73,7 @@ public String get(C carrier, String key) {
7473
});
7574
io.opentelemetry.api.trace.Span span = io.opentelemetry.api.trace.Span.fromContextOrNull(extracted);
7675
OtelTraceContext otelTraceContext = getOtelTraceContext(extracted, span);
77-
78-
try (Scope ignored = extracted.makeCurrent()) {
79-
return OtelSpanBuilder.fromOtel(this.tracer.spanBuilder("")).setParent(otelTraceContext);
80-
}
76+
return OtelSpanBuilder.fromOtel(this.tracer.spanBuilder("")).setParent(otelTraceContext);
8177
}
8278

8379
private static OtelTraceContext getOtelTraceContext(Context extracted, io.opentelemetry.api.trace.Span span) {

spring-cloud-sleuth-otel/src/test/java/org/springframework/cloud/sleuth/otel/bridge/BaggageTests.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,9 @@
2323

2424
import io.opentelemetry.api.baggage.Baggage;
2525
import io.opentelemetry.api.baggage.propagation.W3CBaggagePropagator;
26+
import io.opentelemetry.api.trace.propagation.W3CTraceContextPropagator;
2627
import io.opentelemetry.context.propagation.ContextPropagators;
2728
import io.opentelemetry.context.propagation.TextMapPropagator;
28-
import io.opentelemetry.extension.trace.propagation.B3Propagator;
2929
import io.opentelemetry.sdk.OpenTelemetrySdk;
3030
import io.opentelemetry.sdk.trace.SdkTracerProvider;
3131
import org.junit.jupiter.api.Test;
@@ -49,7 +49,7 @@ class BaggageTests {
4949
Collections.singletonList(KEY_1), Collections.emptyList(), Function.identity()::apply);
5050

5151
ContextPropagators contextPropagators = ContextPropagators.create(
52-
TextMapPropagator.composite(W3CBaggagePropagator.getInstance(), B3Propagator.injectingSingleHeader(),
52+
TextMapPropagator.composite(W3CBaggagePropagator.getInstance(), W3CTraceContextPropagator.getInstance(),
5353
new BaggageTextMapPropagator(Collections.singletonList(KEY_1), otelBaggageManager)));
5454

5555
SdkTracerProvider sdkTracerProvider = SdkTracerProvider.builder()

spring-cloud-sleuth-otel/src/test/java/org/springframework/cloud/sleuth/otel/bridge/OtelPropagatorTests.java

Lines changed: 5 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -97,7 +97,8 @@ void should_propagate_context_with_baggage_only() {
9797

9898
@Test
9999
void should_use_created_child_context_in_scope_instead_of_parent() {
100-
OtelBaggageManager baggageManager = new OtelBaggageManager(otelCurrentTraceContext, Collections.emptyList(), Collections.emptyList(), Function.identity()::apply);
100+
OtelBaggageManager baggageManager = new OtelBaggageManager(otelCurrentTraceContext, Collections.emptyList(),
101+
Collections.emptyList(), Function.identity()::apply);
101102
OtelTracer tracer = new OtelTracer(otelTracer, Function.identity()::apply, baggageManager);
102103

103104
Map<String, String> carrier = new HashMap<>();
@@ -107,19 +108,15 @@ void should_use_created_child_context_in_scope_instead_of_parent() {
107108
String expectedSpanId = extracted.context().spanId();
108109

109110
try (Tracer.SpanInScope ignored = tracer.withSpan(extracted)) {
110-
assertThat(tracer.currentSpan())
111-
.extracting(Span::context)
112-
.returns(expectedSpanId, TraceContext::spanId)
111+
assertThat(tracer.currentSpan()).extracting(Span::context).returns(expectedSpanId, TraceContext::spanId)
113112
.returns("3e425f2373d89640bde06e8285e7bf88", TraceContext::traceId)
114113
.returns("9a5fdefae3abb440", TraceContext::parentId);
115114

116-
assertThat(tracer.currentTraceContext())
117-
.isNotNull()
118-
.extracting(CurrentTraceContext::context)
119-
.isNotNull()
115+
assertThat(tracer.currentTraceContext()).isNotNull().extracting(CurrentTraceContext::context).isNotNull()
120116
.returns(expectedSpanId, TraceContext::spanId)
121117
.returns("3e425f2373d89640bde06e8285e7bf88", TraceContext::traceId)
122118
.returns("9a5fdefae3abb440", TraceContext::parentId);
123119
}
124120
}
121+
125122
}

0 commit comments

Comments
 (0)