diff --git a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RequestData.java b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RequestData.java index bb7fc33e..fb61cb5d 100644 --- a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RequestData.java +++ b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RequestData.java @@ -29,7 +29,8 @@ import org.springframework.util.MultiValueMap; import org.springframework.web.reactive.function.client.ClientRequest; /** - * Represents the data of the request that can be safely read (without passing request reactive stream values). + * Represents the data of the request that can be safely read (without passing request + * reactive stream values). * * @author Olga Maciaszek-Sharma * @since 3.0.0 diff --git a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/ResponseData.java b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/ResponseData.java index 8405c35e..3f130d30 100644 --- a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/ResponseData.java +++ b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/ResponseData.java @@ -26,7 +26,8 @@ import org.springframework.util.MultiValueMap; import org.springframework.web.reactive.function.client.ClientResponse; /** - * Represents the data of the request that can be safely read (without passing request reactive stream values). + * Represents the data of the request that can be safely read (without passing request + * reactive stream values). * * @author Olga Maciaszek-Sharma * @since 3.0.0 diff --git a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RetryLoadBalancerInterceptor.java b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RetryLoadBalancerInterceptor.java index 48038d3f..b9ac8138 100644 --- a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RetryLoadBalancerInterceptor.java +++ b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RetryLoadBalancerInterceptor.java @@ -116,8 +116,8 @@ public class RetryLoadBalancerInterceptor implements ClientHttpRequestIntercepto } Response lbResponse = new DefaultResponse(serviceInstance); if (serviceInstance == null) { - supportedLifecycleProcessors.forEach( - lifecycle -> lifecycle.onComplete(new CompletionContext( + supportedLifecycleProcessors + .forEach(lifecycle -> lifecycle.onComplete(new CompletionContext( CompletionContext.Status.DISCARD, lbResponse))); } ClientHttpResponse response = RetryLoadBalancerInterceptor.this.loadBalancer.execute(serviceName, diff --git a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/RetryableLoadBalancerExchangeFilterFunction.java b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/RetryableLoadBalancerExchangeFilterFunction.java index 880eee7b..34dd5a6d 100644 --- a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/RetryableLoadBalancerExchangeFilterFunction.java +++ b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/RetryableLoadBalancerExchangeFilterFunction.java @@ -131,7 +131,7 @@ public class RetryableLoadBalancerExchangeFilterFunction implements LoadBalanced stickySessionProperties.isAddServiceInstanceCookie()); return next.exchange(newRequest) .doOnError(throwable -> supportedLifecycleProcessors.forEach( - lifecycle -> lifecycle.onComplete(new CompletionContext( + lifecycle -> lifecycle.onComplete(new CompletionContext( CompletionContext.Status.FAILED, throwable, lbResponse)))) .doOnSuccess(clientResponse -> supportedLifecycleProcessors.forEach( lifecycle -> lifecycle.onComplete(new CompletionContext<>(CompletionContext.Status.SUCCESS,