diff --git a/spring-web/src/main/java/org/springframework/web/client/RestTemplate.java b/spring-web/src/main/java/org/springframework/web/client/RestTemplate.java index 7c9190d98c..a5d4e93ac6 100644 --- a/spring-web/src/main/java/org/springframework/web/client/RestTemplate.java +++ b/spring-web/src/main/java/org/springframework/web/client/RestTemplate.java @@ -849,9 +849,7 @@ public class RestTemplate extends InterceptingHttpAccessor implements RestOperat if (requestCallback != null) { requestCallback.doWithRequest(request); } - try (Observation.Scope scope = observation.openScope()) { - response = request.execute(); - } + response = request.execute(); observationContext.setResponse(response); handleResponse(url, method, response); return (responseExtractor != null ? responseExtractor.extractData(response) : null); diff --git a/spring-web/src/main/java/org/springframework/web/observation/reactive/HttpRequestsObservationWebFilter.java b/spring-web/src/main/java/org/springframework/web/observation/reactive/HttpRequestsObservationWebFilter.java index 060550010b..d8182162d7 100644 --- a/spring-web/src/main/java/org/springframework/web/observation/reactive/HttpRequestsObservationWebFilter.java +++ b/spring-web/src/main/java/org/springframework/web/observation/reactive/HttpRequestsObservationWebFilter.java @@ -97,8 +97,8 @@ public class HttpRequestsObservationWebFilter implements WebFilter { } private Publisher filter(ServerWebExchange exchange, HttpRequestsObservationContext observationContext, Mono call) { - Observation observation = Observation.createNotStarted(this.observationConvention, DEFAULT_OBSERVATION_CONVENTION, - observationContext, this.observationRegistry); + Observation observation = HttpRequestsObservation.HTTP_REQUESTS.createNotStarted(this.observationConvention, + DEFAULT_OBSERVATION_CONVENTION, () -> observationContext, this.observationRegistry); observation.start(); return call.doOnEach(signal -> { Throwable throwable = signal.getThrowable();