Rename classes after review.
This commit is contained in:
@@ -42,8 +42,8 @@ public class AsyncLoadBalancerInterceptor implements AsyncClientHttpRequestInter
|
||||
final AsyncClientHttpRequestExecution execution) throws IOException {
|
||||
final URI originalUri = request.getURI();
|
||||
String serviceName = originalUri.getHost();
|
||||
return loadBalancer.execute(serviceName, new DefaultAsyncLoadBalancerRequest(loadBalancer,
|
||||
new DefaultAsyncLoadBalancerRequest.ClientHttpRequestData(request, body, execution)));
|
||||
return loadBalancer.execute(serviceName, new AsyncLoadBalancerRequest(loadBalancer,
|
||||
new AsyncLoadBalancerRequest.ClientHttpRequestData(request, body, execution)));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -28,13 +28,13 @@ import org.springframework.util.concurrent.ListenableFuture;
|
||||
* @author Olga Maciaszek-Sharma
|
||||
* @since 3.1.2
|
||||
*/
|
||||
class DefaultAsyncLoadBalancerRequest implements HttpRequestLoadBalancerRequest<ListenableFuture<ClientHttpResponse>> {
|
||||
class AsyncLoadBalancerRequest implements HttpRequestLoadBalancerRequest<ListenableFuture<ClientHttpResponse>> {
|
||||
|
||||
private final LoadBalancerClient loadBalancer;
|
||||
|
||||
private final ClientHttpRequestData clientHttpRequestData;
|
||||
|
||||
DefaultAsyncLoadBalancerRequest(LoadBalancerClient loadBalancer, ClientHttpRequestData clientHttpRequestData) {
|
||||
AsyncLoadBalancerRequest(LoadBalancerClient loadBalancer, ClientHttpRequestData clientHttpRequestData) {
|
||||
this.loadBalancer = loadBalancer;
|
||||
this.clientHttpRequestData = clientHttpRequestData;
|
||||
}
|
||||
@@ -29,7 +29,7 @@ import org.springframework.http.client.ClientHttpResponse;
|
||||
* @author Olga Maciaszek-Sharma
|
||||
* @since 3.1.2
|
||||
*/
|
||||
class DefaultLoadBalancerRequest implements HttpRequestLoadBalancerRequest<ClientHttpResponse> {
|
||||
class BlockingLoadBalancerRequest implements HttpRequestLoadBalancerRequest<ClientHttpResponse> {
|
||||
|
||||
private final LoadBalancerClient loadBalancer;
|
||||
|
||||
@@ -37,7 +37,7 @@ class DefaultLoadBalancerRequest implements HttpRequestLoadBalancerRequest<Clien
|
||||
|
||||
private final ClientHttpRequestData clientHttpRequestData;
|
||||
|
||||
DefaultLoadBalancerRequest(LoadBalancerClient loadBalancer, List<LoadBalancerRequestTransformer> transformers,
|
||||
BlockingLoadBalancerRequest(LoadBalancerClient loadBalancer, List<LoadBalancerRequestTransformer> transformers,
|
||||
ClientHttpRequestData clientHttpRequestData) {
|
||||
this.loadBalancer = loadBalancer;
|
||||
this.transformers = transformers;
|
||||
@@ -51,8 +51,8 @@ public class LoadBalancerRequestFactory {
|
||||
|
||||
public LoadBalancerRequest<ClientHttpResponse> createRequest(final HttpRequest request, final byte[] body,
|
||||
final ClientHttpRequestExecution execution) {
|
||||
return new DefaultLoadBalancerRequest(loadBalancer, transformers,
|
||||
new DefaultLoadBalancerRequest.ClientHttpRequestData(request, body, execution));
|
||||
return new BlockingLoadBalancerRequest(loadBalancer, transformers,
|
||||
new BlockingLoadBalancerRequest.ClientHttpRequestData(request, body, execution));
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user