diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java b/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java index 44192837d28..9a2c9f4863b 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/function/client/DefaultWebClient.java @@ -79,7 +79,9 @@ final class DefaultWebClient implements WebClient { private static final Mono NO_HTTP_CLIENT_RESPONSE_ERROR = Mono.error( () -> new IllegalStateException("The underlying HTTP client completed without emitting a response.")); - private static final DefaultClientRequestObservationConvention DEFAULT_OBSERVATION_CONVENTION = new DefaultClientRequestObservationConvention(); + private static final DefaultClientRequestObservationConvention DEFAULT_OBSERVATION_CONVENTION = + new DefaultClientRequestObservationConvention(); + private final ExchangeFunction exchangeFunction; @@ -119,10 +121,10 @@ final class DefaultWebClient implements WebClient { this.uriBuilderFactory = uriBuilderFactory; this.defaultHeaders = defaultHeaders; this.defaultCookies = defaultCookies; - this.observationRegistry = observationRegistry; - this.observationConvention = observationConvention; this.defaultRequest = defaultRequest; this.defaultStatusHandlers = initStatusHandlers(statusHandlerMap); + this.observationRegistry = observationRegistry; + this.observationConvention = observationConvention; this.builder = builder; } @@ -697,7 +699,7 @@ final class DefaultWebClient implements WebClient { private static URI getUriToLog(URI uri) { if (StringUtils.hasText(uri.getQuery())) { try { - uri = new URI(uri.getScheme(), uri.getHost(), uri.getPath(), null); + uri = new URI(uri.getScheme(), null, uri.getHost(), uri.getPort(), uri.getPath(), null, null); } catch (URISyntaxException ex) { // ignore