From b9f7bcb002a4133fa57cc525fcac9c26bc3e3d53 Mon Sep 17 00:00:00 2001 From: sgibb Date: Fri, 8 Mar 2024 16:10:56 -0500 Subject: [PATCH] Formatting --- .../cloud/gateway/sample/ThrottleGatewayFilter.java | 1 - .../gateway/filter/ReactiveLoadBalancerClientFilter.java | 7 ++++--- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-cloud-gateway-sample/src/main/java/org/springframework/cloud/gateway/sample/ThrottleGatewayFilter.java b/spring-cloud-gateway-sample/src/main/java/org/springframework/cloud/gateway/sample/ThrottleGatewayFilter.java index b44923c0..9cf02b42 100644 --- a/spring-cloud-gateway-sample/src/main/java/org/springframework/cloud/gateway/sample/ThrottleGatewayFilter.java +++ b/spring-cloud-gateway-sample/src/main/java/org/springframework/cloud/gateway/sample/ThrottleGatewayFilter.java @@ -46,7 +46,6 @@ public class ThrottleGatewayFilter implements GatewayFilter { TimeUnit refillUnit; - private TokenBucket getTokenBucket() { if (tokenBucket != null) { return tokenBucket; diff --git a/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/ReactiveLoadBalancerClientFilter.java b/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/ReactiveLoadBalancerClientFilter.java index fff51042..1aabf6e8 100644 --- a/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/ReactiveLoadBalancerClientFilter.java +++ b/spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/ReactiveLoadBalancerClientFilter.java @@ -113,8 +113,8 @@ public class ReactiveLoadBalancerClientFilter implements GlobalFilter, Ordered { Set supportedLifecycleProcessors = LoadBalancerLifecycleValidator .getSupportedLifecycleProcessors(clientFactory.getInstances(serviceId, LoadBalancerLifecycle.class), RequestDataContext.class, ResponseData.class, ServiceInstance.class); - DefaultRequest lbRequest = new DefaultRequest<>( - new RequestDataContext(new RequestData(exchange.getRequest(), exchange.getAttributes()), getHint(serviceId))); + DefaultRequest lbRequest = new DefaultRequest<>(new RequestDataContext( + new RequestData(exchange.getRequest(), exchange.getAttributes()), getHint(serviceId))); return choose(lbRequest, serviceId, supportedLifecycleProcessors).doOnNext(response -> { if (!response.hasServer()) { @@ -154,7 +154,8 @@ public class ReactiveLoadBalancerClientFilter implements GlobalFilter, Ordered { .onComplete(new CompletionContext( CompletionContext.Status.SUCCESS, lbRequest, exchange.getAttribute(GATEWAY_LOADBALANCER_RESPONSE_ATTR), - new ResponseData(exchange.getResponse(), new RequestData(exchange.getRequest(), exchange.getAttributes())))))); + new ResponseData(exchange.getResponse(), + new RequestData(exchange.getRequest(), exchange.getAttributes())))))); } protected URI reconstructURI(ServiceInstance serviceInstance, URI original) {