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

Formatting for 3.1.x

Browse Source
This commit is contained in:
spencergibb
2023-01-24 15:13:38 -05:00
parent 2d67158c20
commit 22536f2702
4 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/GatewayFilterChain.java
View File

@@ -24,6 +24,7 @@ import org.springframework.web.server.ServerWebExchange;
* Contract to allow a {@link GatewayFilter} to delegate to the next in the chain.
*
* Copied from framework WebFilterChain
*
* @author Rossen Stoyanchev
* @since 5.0
*/

7
spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/GlobalFilter.java
View File

@@ -21,13 +21,14 @@ import reactor.core.publisher.Mono;
import org.springframework.web.server.ServerWebExchange;
/**
* Contract for interception-style, chained processing of gateway requests that may be used to
* implement cross-cutting, application-agnostic requirements such as security, timeouts,
* and others.
* Contract for interception-style, chained processing of gateway requests that may be
* used to implement cross-cutting, application-agnostic requirements such as security,
* timeouts, and others.
*
* Only applies to matched gateway routes.
*
* Copied from framework WebFilter
*
* @author Rossen Stoyanchev
* @since 5.0
*/

4
spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/factory/CacheRequestBodyGatewayFilterFactory.java
View File

@@ -89,8 +89,8 @@ public class CacheRequestBodyGatewayFilterFactory
//
Object backupCachedBody = exchange.getAttributes()
.get(CACHED_ORIGINAL_REQUEST_BODY_BACKUP_ATTR);
if (backupCachedBody instanceof DataBuffer backupCachedDataBuffer) {
DataBufferUtils.release(backupCachedDataBuffer);
if (backupCachedBody instanceof DataBuffer) {
DataBufferUtils.release((DataBuffer) backupCachedBody);
}
});
}));

5
spring-cloud-gateway-server/src/test/java/org/springframework/cloud/gateway/filter/factory/CacheRequestBodyGatewayFilterFactoryTests.java
View File

@@ -174,8 +174,9 @@ public class CacheRequestBodyGatewayFilterFactoryTests extends BaseWebClientTest
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
return chain.filter(exchange).doAfterTerminate(() -> {
Object o = exchange.getAttributes()
.get(CacheRequestBodyGatewayFilterFactory.CACHED_ORIGIN_REQUEST_BODY_BACKUP_ATTR);
if (o instanceof PooledDataBuffer dataBuffer) {
.get(CacheRequestBodyGatewayFilterFactory.CACHED_ORIGINAL_REQUEST_BODY_BACKUP_ATTR);
if (o instanceof PooledDataBuffer) {
PooledDataBuffer dataBuffer = (PooledDataBuffer) o;
if (dataBuffer.isAllocated()) {
exchange.getResponse().setStatusCode(HttpStatus.INTERNAL_SERVER_ERROR);
fail("DataBuffer is not released");