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

Fix generics.

Browse Source
This commit is contained in:
Olga Maciaszek-Sharma
2020-12-09 14:14:15 +01:00
parent dce413ae66
commit 28e096573a
4 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RequestData.java
View File

@@ -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

3
spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/ResponseData.java
View File

@@ -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

4
spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/RetryLoadBalancerInterceptor.java
View File

@@ -116,8 +116,8 @@ public class RetryLoadBalancerInterceptor implements ClientHttpRequestIntercepto
}
Response<ServiceInstance> lbResponse = new DefaultResponse(serviceInstance);
if (serviceInstance == null) {
supportedLifecycleProcessors.forEach(
lifecycle -> lifecycle.onComplete(new CompletionContext<ClientHttpResponse, ServiceInstance>(
supportedLifecycleProcessors
.forEach(lifecycle -> lifecycle.onComplete(new CompletionContext<ResponseData, ServiceInstance>(
CompletionContext.Status.DISCARD, lbResponse)));
}
ClientHttpResponse response = RetryLoadBalancerInterceptor.this.loadBalancer.execute(serviceName,

2
spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/RetryableLoadBalancerExchangeFilterFunction.java
View File

@@ -131,7 +131,7 @@ public class RetryableLoadBalancerExchangeFilterFunction implements LoadBalanced
stickySessionProperties.isAddServiceInstanceCookie());
return next.exchange(newRequest)
.doOnError(throwable -> supportedLifecycleProcessors.forEach(
lifecycle -> lifecycle.onComplete(new CompletionContext<ClientResponse, ServiceInstance>(
lifecycle -> lifecycle.onComplete(new CompletionContext<ResponseData, ServiceInstance>(
CompletionContext.Status.FAILED, throwable, lbResponse))))
.doOnSuccess(clientResponse -> supportedLifecycleProcessors.forEach(
lifecycle -> lifecycle.onComplete(new CompletionContext<>(CompletionContext.Status.SUCCESS,