Commit bbbf8c52 authored by Brian Clozel's avatar Brian Clozel

Polish

See gh-20205
parent a7e57e09
...@@ -35,7 +35,8 @@ public class CodecProperties { ...@@ -35,7 +35,8 @@ public class CodecProperties {
/** /**
* Limit on the number of bytes that can be buffered whenever the input stream needs * Limit on the number of bytes that can be buffered whenever the input stream needs
* to be aggregated. By default this is not set, in which case individual codec * to be aggregated. This applies only to the auto-configured WebFlux server and
* WebClient instances. By default this is not set, in which case individual codec
* defaults apply. Most codecs are limited to 256K by default. * defaults apply. Most codecs are limited to 256K by default.
*/ */
private DataSize maxInMemorySize; private DataSize maxInMemorySize;
......
/* /*
* Copyright 2012-2019 the original author or authors. * Copyright 2012-2020 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
...@@ -54,7 +54,7 @@ public class ReactiveRestClientAutoConfiguration { ...@@ -54,7 +54,7 @@ public class ReactiveRestClientAutoConfiguration {
builder.usingSsl(); builder.usingSsl();
} }
configureTimeouts(builder, properties); configureTimeouts(builder, properties);
configureWebClient(builder, properties); configureExchangeStrategies(builder, properties);
return builder.build(); return builder.build();
} }
...@@ -70,7 +70,7 @@ public class ReactiveRestClientAutoConfiguration { ...@@ -70,7 +70,7 @@ public class ReactiveRestClientAutoConfiguration {
}); });
} }
private void configureWebClient(ClientConfiguration.TerminalClientConfigurationBuilder builder, private void configureExchangeStrategies(ClientConfiguration.TerminalClientConfigurationBuilder builder,
ReactiveRestClientProperties properties) { ReactiveRestClientProperties properties) {
PropertyMapper map = PropertyMapper.get(); PropertyMapper map = PropertyMapper.get();
builder.withWebClientConfigurer((webClient) -> { builder.withWebClientConfigurer((webClient) -> {
......
/* /*
* Copyright 2012-2019 the original author or authors. * Copyright 2012-2020 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
......
...@@ -77,7 +77,6 @@ public class ReactiveRestClientAutoConfigurationTests { ...@@ -77,7 +77,6 @@ public class ReactiveRestClientAutoConfigurationTests {
this.contextRunner.withPropertyValues( this.contextRunner.withPropertyValues(
"spring.data.elasticsearch.client.reactive.endpoints=" + elasticsearch.getContainerIpAddress() + ":" "spring.data.elasticsearch.client.reactive.endpoints=" + elasticsearch.getContainerIpAddress() + ":"
+ elasticsearch.getFirstMappedPort(), + elasticsearch.getFirstMappedPort(),
"spring.data.elasticsearch.client.reactive.max-in-memory-size=-1",
"spring.data.elasticsearch.client.reactive.connection-timeout=120s", "spring.data.elasticsearch.client.reactive.connection-timeout=120s",
"spring.data.elasticsearch.client.reactive.socket-timeout=120s").run((context) -> { "spring.data.elasticsearch.client.reactive.socket-timeout=120s").run((context) -> {
ReactiveElasticsearchClient client = context.getBean(ReactiveElasticsearchClient.class); ReactiveElasticsearchClient client = context.getBean(ReactiveElasticsearchClient.class);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment