Formatting

Author: spencergibb

spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/ratelimit/Bucket4jRateLimiter.java

@@ -60,7 +60,7 @@ public Mono<Response> isAllowed(String routeId, String id) {
 
 		AsyncBucketProxy bucket = proxyManager.builder().build(id, bucketConfiguration);
 		CompletableFuture<ConsumptionProbe> bucketFuture = bucket
-				.tryConsumeAndReturnRemaining(routeConfig.getRequestedTokens());
+			.tryConsumeAndReturnRemaining(routeConfig.getRequestedTokens());
 		return Mono.fromFuture(bucketFuture).onErrorResume(throwable -> {
 			if (log.isDebugEnabled()) {
 				log.debug("Error calling Bucket4J rate limiter", throwable);
@@ -80,7 +80,8 @@ public Mono<Response> isAllowed(String routeId, String id) {
 
 	protected static BucketConfiguration getBucketConfiguration(Config routeConfig) {
 		return BucketConfiguration.builder()
-				.addLimit(Bandwidth.simple(routeConfig.getCapacity(), routeConfig.getPeriod())).build();
+			.addLimit(Bandwidth.simple(routeConfig.getCapacity(), routeConfig.getPeriod()))
+			.build();
 	}
 
 	protected Config loadRouteConfiguration(String routeId) {
@@ -107,7 +108,7 @@ public Map<String, String> getHeaders(Config config, Long tokensLeft) {
 
 	public static class Config {
 
-		//TODO: create simple and classic w/Refill
+		// TODO: create simple and classic w/Refill
 
 		long capacity;
 
@@ -143,8 +144,10 @@ public Config setRequestedTokens(long requestedTokens) {
 		}
 
 		public String toString() {
-			return new ToStringCreator(this).append("capacity", capacity).append("requestedTokens", requestedTokens)
-					.append("period", period).toString();
+			return new ToStringCreator(this).append("capacity", capacity)
+				.append("requestedTokens", requestedTokens)
+				.append("period", period)
+				.toString();
 		}
 
 	}

spring-cloud-gateway-server/src/test/java/org/springframework/cloud/gateway/filter/ratelimit/Bucket4jRateLimiterTests.java

@@ -65,8 +65,8 @@ public void bucket4jRateLimiterWorks() throws Exception {
 		int requestedTokens = 1;
 
 		String routeId = "myroute";
-		rateLimiter.getConfig().put(routeId,
-				new Bucket4jRateLimiter.Config().setCapacity(capacity).setPeriod(Duration.ofSeconds(1)));
+		rateLimiter.getConfig()
+			.put(routeId, new Bucket4jRateLimiter.Config().setCapacity(capacity).setPeriod(Duration.ofSeconds(1)));
 
 		checkLimitEnforced(id, capacity, requestedTokens, routeId);
 	}
@@ -79,8 +79,11 @@ public void bucket4jRateLimiterIsAllowedFalseWorks() throws Exception {
 		int requestedTokens = 2;
 
 		String routeId = "zero_capacity_route";
-		rateLimiter.getConfig().put(routeId, new Bucket4jRateLimiter.Config().setCapacity(capacity)
-				.setPeriod(Duration.ofSeconds(1)).setRequestedTokens(requestedTokens));
+		rateLimiter.getConfig()
+			.put(routeId,
+					new Bucket4jRateLimiter.Config().setCapacity(capacity)
+						.setPeriod(Duration.ofSeconds(1))
+						.setRequestedTokens(requestedTokens));
 
 		Response response = rateLimiter.isAllowed(routeId, id).block();
 		assertThat(response.isAllowed()).isFalse();