diff --git a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/web/client/TraceExchangeFilterFunction.java b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/web/client/TraceExchangeFilterFunction.java index 65e8b971c..6c5b89279 100644 --- a/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/web/client/TraceExchangeFilterFunction.java +++ b/spring-cloud-sleuth-instrumentation/src/main/java/org/springframework/cloud/sleuth/instrument/web/client/TraceExchangeFilterFunction.java @@ -71,25 +71,7 @@ public final class TraceExchangeFilterFunction implements ExchangeFilterFunction } public static ExchangeFilterFunction create(ConfigurableApplicationContext springContext) { - return new ExchangeFilterFunction() { - - TraceExchangeFilterFunction traceExchangeFilterFunction; - - @Override - public Mono filter(ClientRequest request, ExchangeFunction next) { - if (ContextUtil.isContextUnusable(springContext)) { - return next.exchange(request); - } - return traceExchangeFilterFunction().filter(request, next); - } - - private TraceExchangeFilterFunction traceExchangeFilterFunction() { - if (this.traceExchangeFilterFunction == null) { - this.traceExchangeFilterFunction = new TraceExchangeFilterFunction(springContext); - } - return this.traceExchangeFilterFunction; - } - }; + return new TraceExchangeFilterFunction(springContext); } @Override @@ -175,8 +157,7 @@ public final class TraceExchangeFilterFunction implements ExchangeFilterFunction final Context context; - @Nullable - final TraceContext parent; + @Nullable final TraceContext parent; final HttpClientHandler handler;