diff --git a/spring-test/src/main/java/org/springframework/mock/http/server/reactive/MockServerHttpRequest.java b/spring-test/src/main/java/org/springframework/mock/http/server/reactive/MockServerHttpRequest.java index 2488bdfc03..e938fc5002 100644 --- a/spring-test/src/main/java/org/springframework/mock/http/server/reactive/MockServerHttpRequest.java +++ b/spring-test/src/main/java/org/springframework/mock/http/server/reactive/MockServerHttpRequest.java @@ -78,7 +78,7 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { private MockServerHttpRequest(@Nullable HttpMethod httpMethod, @Nullable String customHttpMethod, URI uri, @Nullable String contextPath, HttpHeaders headers, MultiValueMap cookies, - @Nullable InetSocketAddress remoteAddress, @Nullable InetSocketAddress localAddress, + @Nullable InetSocketAddress localAddress, @Nullable InetSocketAddress remoteAddress, @Nullable SslInfo sslInfo, Publisher body) { super(uri, contextPath, headers); @@ -86,8 +86,8 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { this.httpMethod = httpMethod; this.customHttpMethod = customHttpMethod; this.cookies = cookies; - this.remoteAddress = remoteAddress; this.localAddress = localAddress; + this.remoteAddress = remoteAddress; this.sslInfo = sslInfo; this.body = Flux.from(body); } @@ -382,9 +382,9 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { * @see BodyBuilder#body(String) */ MockServerHttpRequest build(); - } + /** * A builder that adds a body to the request. */ @@ -423,7 +423,6 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { * @return the built request entity */ MockServerHttpRequest body(String body); - } @@ -431,7 +430,6 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { private static final DataBufferFactory BUFFER_FACTORY = new DefaultDataBufferFactory(); - @Nullable private final HttpMethod method; @@ -612,7 +610,7 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { public MockServerHttpRequest body(Publisher body) { applyCookiesIfNecessary(); return new MockServerHttpRequest(this.method, this.customMethod, getUrlToUse(), this.contextPath, - this.headers, this.cookies, this.remoteAddress, this.localAddress, this.sslInfo, body); + this.headers, this.cookies, this.localAddress, this.remoteAddress, this.sslInfo, body); } private void applyCookiesIfNecessary() { @@ -625,11 +623,9 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { private URI getUrlToUse() { MultiValueMap params = this.queryParamsBuilder.buildAndExpand().encode().getQueryParams(); - if (!params.isEmpty()) { return UriComponentsBuilder.fromUri(this.url).queryParams(params).build(true).toUri(); } - return this.url; } } diff --git a/spring-web/src/testFixtures/java/org/springframework/web/testfixture/http/server/reactive/MockServerHttpRequest.java b/spring-web/src/testFixtures/java/org/springframework/web/testfixture/http/server/reactive/MockServerHttpRequest.java index 4f0ab79882..70a566f199 100644 --- a/spring-web/src/testFixtures/java/org/springframework/web/testfixture/http/server/reactive/MockServerHttpRequest.java +++ b/spring-web/src/testFixtures/java/org/springframework/web/testfixture/http/server/reactive/MockServerHttpRequest.java @@ -78,7 +78,7 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { private MockServerHttpRequest(@Nullable HttpMethod httpMethod, @Nullable String customHttpMethod, URI uri, @Nullable String contextPath, HttpHeaders headers, MultiValueMap cookies, - @Nullable InetSocketAddress remoteAddress, @Nullable InetSocketAddress localAddress, + @Nullable InetSocketAddress localAddress, @Nullable InetSocketAddress remoteAddress, @Nullable SslInfo sslInfo, Publisher body) { super(uri, contextPath, headers); @@ -86,8 +86,8 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { this.httpMethod = httpMethod; this.customHttpMethod = customHttpMethod; this.cookies = cookies; - this.remoteAddress = remoteAddress; this.localAddress = localAddress; + this.remoteAddress = remoteAddress; this.sslInfo = sslInfo; this.body = Flux.from(body); } @@ -382,9 +382,9 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { * @see BodyBuilder#body(String) */ MockServerHttpRequest build(); - } + /** * A builder that adds a body to the request. */ @@ -423,7 +423,6 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { * @return the built request entity */ MockServerHttpRequest body(String body); - } @@ -431,7 +430,6 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { private static final DataBufferFactory BUFFER_FACTORY = new DefaultDataBufferFactory(); - @Nullable private final HttpMethod method; @@ -612,7 +610,7 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { public MockServerHttpRequest body(Publisher body) { applyCookiesIfNecessary(); return new MockServerHttpRequest(this.method, this.customMethod, getUrlToUse(), this.contextPath, - this.headers, this.cookies, this.remoteAddress, this.localAddress, this.sslInfo, body); + this.headers, this.cookies, this.localAddress, this.remoteAddress, this.sslInfo, body); } private void applyCookiesIfNecessary() { @@ -625,11 +623,9 @@ public final class MockServerHttpRequest extends AbstractServerHttpRequest { private URI getUrlToUse() { MultiValueMap params = this.queryParamsBuilder.buildAndExpand().encode().getQueryParams(); - if (!params.isEmpty()) { return UriComponentsBuilder.fromUri(this.url).queryParams(params).build(true).toUri(); } - return this.url; } } diff --git a/spring-webflux/src/main/java/org/springframework/web/reactive/config/WebFluxConfigurationSupport.java b/spring-webflux/src/main/java/org/springframework/web/reactive/config/WebFluxConfigurationSupport.java index 02283d1eb1..e7061ce425 100644 --- a/spring-webflux/src/main/java/org/springframework/web/reactive/config/WebFluxConfigurationSupport.java +++ b/spring-webflux/src/main/java/org/springframework/web/reactive/config/WebFluxConfigurationSupport.java @@ -273,6 +273,7 @@ public class WebFluxConfigurationSupport implements ApplicationContextAware { ServerCodecConfigurer serverCodecConfigurer, @Qualifier("webFluxConversionService") FormattingConversionService conversionService, @Qualifier("webFluxValidator") Validator validator) { + RequestMappingHandlerAdapter adapter = createRequestMappingHandlerAdapter(); adapter.setMessageReaders(serverCodecConfigurer.getReaders()); adapter.setWebBindingInitializer(getConfigurableWebBindingInitializer(conversionService, validator));