Skip to content

Commit 2708f53

Browse files
committed
polishing
1 parent a34c071 commit 2708f53

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

spring-cloud-gateway-server-webmvc/src/main/java/org/springframework/cloud/gateway/server/mvc/filter/Bucket4jFilterFunctions.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -65,15 +65,14 @@ public static HandlerFilterFunction<ServerResponse, ServerResponse> rateLimit(
6565
Consumer<RateLimitConfig> configConsumer) {
6666
RateLimitConfig config = new RateLimitConfig();
6767
configConsumer.accept(config);
68-
BucketConfiguration bucketConfiguration = config.getConfigurationBuilder().apply(config);
6968
return (request, next) -> {
7069
AsyncProxyManager proxyManager = MvcUtils.getApplicationContext(request).getBean(AsyncProxyManager.class);
7170
String key = config.getKeyResolver().apply(request);
7271
if (!StringUtils.hasText(key)) {
7372
// TODO: configurable empty key status code
7473
return ServerResponse.status(HttpStatus.FORBIDDEN).build();
7574
}
76-
AsyncBucketProxy bucket = proxyManager.builder().build(key, bucketConfiguration);
75+
AsyncBucketProxy bucket = proxyManager.builder().build(key, () -> config.configurationBuilder.apply(config));
7776
CompletableFuture<ConsumptionProbe> bucketFuture = bucket.tryConsumeAndReturnRemaining(config.getTokens());
7877
ConsumptionProbe consumptionProbe;
7978
if (config.getTimeout() != null) {

spring-cloud-gateway-server-webmvc/src/main/java/org/springframework/cloud/gateway/server/mvc/filter/RetryFilterFunctions.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -51,18 +51,21 @@ private RetryFilterFunctions() {
5151
}
5252

5353
@Shortcut
54+
@SuppressWarnings("deprecation")
5455
public static HandlerFilterFunction<ServerResponse, ServerResponse> retry(int retries) {
5556
return useSpringRetry() ? GatewayRetryFilterFunctions.retry(retries)
5657
: FrameworkRetryFilterFunctions.frameworkRetry(retries);
5758
}
5859

60+
@SuppressWarnings("deprecation")
5961
public static HandlerFilterFunction<ServerResponse, ServerResponse> retry(Consumer<RetryConfig> configConsumer) {
6062
return useSpringRetry() ? GatewayRetryFilterFunctions.retry(configConsumer)
6163
: FrameworkRetryFilterFunctions.frameworkRetry(configConsumer);
6264
}
6365

6466
@Shortcut({ "retries", "series", "methods" })
6567
@Configurable
68+
@SuppressWarnings("deprecation")
6669
public static HandlerFilterFunction<ServerResponse, ServerResponse> retry(RetryConfig config) {
6770
return useSpringRetry() ? GatewayRetryFilterFunctions.retry(config)
6871
: FrameworkRetryFilterFunctions.frameworkRetry(config);

0 commit comments

Comments
 (0)