SpringCloud/spring-cloud-gateway
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add a new method that returns a Mono<HttpClient>. (#2993)

Browse Source 
Delegate implementation to existing getHttpClient method.

Fixes gh-2991
This commit is contained in:
jeremy-l-ford
2024-03-08 14:32:27 -05:00
committed by GitHub
parent 7968b0da99
commit 7d9c634364
1 changed files with 14 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/NettyRoutingFilter.java
View File

@@ -130,7 +130,7 @@ public class NettyRoutingFilter implements GlobalFilter, Ordered {
boolean preserveHost = exchange.getAttributeOrDefault(PRESERVE_HOST_HEADER_ATTRIBUTE, false);
Route route = exchange.getAttribute(GATEWAY_ROUTE_ATTR);
Flux<HttpClientResponse> responseFlux = getHttpClient(route, exchange).headers(headers -> {
Flux<HttpClientResponse> responseFlux = httpClient(route, exchange).flatMapMany(hc -> hc.headers(headers -> {
headers.add(httpHeaders);
// Will either be set below, or later by Netty
headers.remove(HttpHeaders.HOST);
@@ -184,7 +184,7 @@ public class NettyRoutingFilter implements GlobalFilter, Ordered {
response.getHeaders().addAll(filteredResponseHeaders);
return Mono.just(res);
});
}));
Duration responseTimeout = getResponseTimeout(route);
if (responseTimeout != null) {
@@ -231,6 +231,18 @@ public class NettyRoutingFilter implements GlobalFilter, Ordered {
}
}
/**
* Creates a new HttpClient with per route timeout configuration. Sub-classes that
* override, should call super.httpClient() if they want to honor the per route
* timeout configuration.
* @param route the current route.
* @param exchange the current ServerWebExchange.
* @return the configured HttpClient.
*/
protected Mono<HttpClient> httpClient(Route route, ServerWebExchange exchange) {
return Mono.just(getHttpClient(route, exchange));
}
/**
* Creates a new HttpClient with per route timeout configuration. Sub-classes that
* override, should call super.getHttpClient() if they want to honor the per route