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

Update to new Repeat.create() method

Browse Source
This commit is contained in:
Spencer Gibb
2018-02-28 18:39:52 -05:00
parent d2a1f5b896
commit 8fc23f8ab0
1 changed files with 1 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-cloud-gateway-core/src/main/java/org/springframework/cloud/gateway/filter/factory/RetryGatewayFilterFactory.java
View File

@@ -66,12 +66,6 @@ public class RetryGatewayFilterFactory implements GatewayFilterFactory {
retry.validate();
Predicate<? super RepeatContext<ServerWebExchange>> predicate = context -> {
boolean retryableAttempt = context.iteration() < retry.getRetries();
if (!retryableAttempt) {
return false;
}
ServerWebExchange exchange = context.applicationContext();
HttpStatus statusCode = exchange.getResponse().getStatusCode();
HttpMethod httpMethod = exchange.getRequest().getMethod();
@@ -88,8 +82,7 @@ public class RetryGatewayFilterFactory implements GatewayFilterFactory {
return retryableMethod && retryableStatusCode;
};
//TODO: use Repeat statics once updated with a create() like method
Repeat<ServerWebExchange> repeat = Repeat.onlyIf(predicate);
Repeat<ServerWebExchange> repeat = Repeat.create(predicate, retry.getRetries());
//TODO: support timeout, backoff, jitter, etc... in Builder
return apply(repeat);