formatting
This commit is contained in:
@@ -99,7 +99,6 @@ public class RedisRateLimiterTests extends BaseWebClientTests {
|
||||
checkLimitEnforced(id, replenishRate, burstCapacity, requestedTokens, routeId);
|
||||
}
|
||||
|
||||
|
||||
@Test
|
||||
public void redisRateLimiterWorksForMultipleRoutes() throws Exception {
|
||||
String id = UUID.randomUUID().toString();
|
||||
@@ -111,13 +110,15 @@ public class RedisRateLimiterTests extends BaseWebClientTests {
|
||||
String firstRouteId = "myroute";
|
||||
String secondRouteId = "myroute2";
|
||||
var config = rateLimiter.getConfig();
|
||||
config.put(firstRouteId, new RedisRateLimiter.Config().setBurstCapacity(burstCapacity)
|
||||
.setReplenishRate(replenishRate)
|
||||
.setRequestedTokens(requestedTokens));
|
||||
config.put(firstRouteId,
|
||||
new RedisRateLimiter.Config().setBurstCapacity(burstCapacity)
|
||||
.setReplenishRate(replenishRate)
|
||||
.setRequestedTokens(requestedTokens));
|
||||
|
||||
config.put(secondRouteId, new RedisRateLimiter.Config().setBurstCapacity(burstCapacity)
|
||||
.setReplenishRate(replenishRate)
|
||||
.setRequestedTokens(requestedTokens));
|
||||
config.put(secondRouteId,
|
||||
new RedisRateLimiter.Config().setBurstCapacity(burstCapacity)
|
||||
.setReplenishRate(replenishRate)
|
||||
.setRequestedTokens(requestedTokens));
|
||||
|
||||
checkLimitEnforced(id, replenishRate, burstCapacity, requestedTokens, firstRouteId);
|
||||
checkLimitEnforced(id, replenishRate, burstCapacity, requestedTokens, secondRouteId);
|
||||
|
||||
@@ -96,14 +96,20 @@ public class RoutePredicateHandlerMappingIntegrationTests extends BaseWebClientT
|
||||
|
||||
@Test
|
||||
public void andNestedOrQuery1() {
|
||||
testClient.get().uri("/andnestedquery?query1=hasquery1").exchange().expectBody(String.class)
|
||||
.isEqualTo("hasquery1,notsupplied");
|
||||
testClient.get()
|
||||
.uri("/andnestedquery?query1=hasquery1")
|
||||
.exchange()
|
||||
.expectBody(String.class)
|
||||
.isEqualTo("hasquery1,notsupplied");
|
||||
}
|
||||
|
||||
@Test
|
||||
public void andNestedOrQuery2() {
|
||||
testClient.get().uri("/andnestedquery?query2=hasquery2").exchange().expectBody(String.class)
|
||||
.isEqualTo("notsupplied,hasquery2");
|
||||
testClient.get()
|
||||
.uri("/andnestedquery?query2=hasquery2")
|
||||
.exchange()
|
||||
.expectBody(String.class)
|
||||
.isEqualTo("notsupplied,hasquery2");
|
||||
}
|
||||
|
||||
@EnableAutoConfiguration
|
||||
@@ -146,8 +152,12 @@ public class RoutePredicateHandlerMappingIntegrationTests extends BaseWebClientT
|
||||
.query("myquery")
|
||||
.filters(f -> f.setPath("/httpbin/hasquery"))
|
||||
.uri(uri))
|
||||
.route("and_nested_query1_or_query2", r -> r.path("/andnestedquery").and().nested(p -> p.query("query1").or().query("query2"))
|
||||
.filters(f -> f.prefixPath("/httpbin")).uri(uri))
|
||||
.route("and_nested_query1_or_query2",
|
||||
r -> r.path("/andnestedquery")
|
||||
.and()
|
||||
.nested(p -> p.query("query1").or().query("query2"))
|
||||
.filters(f -> f.prefixPath("/httpbin"))
|
||||
.uri(uri))
|
||||
.build();
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user