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

Formatting

Browse Source
This commit is contained in:
sgibb
2024-03-08 16:10:56 -05:00
parent e6d237c4d7
commit b9f7bcb002
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
spring-cloud-gateway-sample/src/main/java/org/springframework/cloud/gateway/sample/ThrottleGatewayFilter.java
View File

@@ -46,7 +46,6 @@ public class ThrottleGatewayFilter implements GatewayFilter {
TimeUnit refillUnit;
private TokenBucket getTokenBucket() {
if (tokenBucket != null) {
return tokenBucket;

7
spring-cloud-gateway-server/src/main/java/org/springframework/cloud/gateway/filter/ReactiveLoadBalancerClientFilter.java
View File

@@ -113,8 +113,8 @@ public class ReactiveLoadBalancerClientFilter implements GlobalFilter, Ordered {
Set<LoadBalancerLifecycle> supportedLifecycleProcessors = LoadBalancerLifecycleValidator
.getSupportedLifecycleProcessors(clientFactory.getInstances(serviceId, LoadBalancerLifecycle.class),
RequestDataContext.class, ResponseData.class, ServiceInstance.class);
DefaultRequest<RequestDataContext> lbRequest = new DefaultRequest<>(
new RequestDataContext(new RequestData(exchange.getRequest(), exchange.getAttributes()), getHint(serviceId)));
DefaultRequest<RequestDataContext> 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<ResponseData, ServiceInstance, RequestDataContext>(
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) {