diff --git a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/DefaultFeignLoadBalancerConfiguration.java b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/DefaultFeignLoadBalancerConfiguration.java index 16089f0f..8401c46c 100644 --- a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/DefaultFeignLoadBalancerConfiguration.java +++ b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/DefaultFeignLoadBalancerConfiguration.java @@ -53,7 +53,7 @@ class DefaultFeignLoadBalancerConfiguration { matchIfMissing = true) public Client feignRetryClient(LoadBalancerClient loadBalancerClient, LoadBalancedRetryFactory loadBalancedRetryFactory) { - return new RetryableBlockingFeignLoadBalancerClient(new Client.Default(null, null), loadBalancerClient, + return new RetryableFeignBlockingLoadBalancerClient(new Client.Default(null, null), loadBalancerClient, loadBalancedRetryFactory); } diff --git a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/HttpClientFeignLoadBalancerConfiguration.java b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/HttpClientFeignLoadBalancerConfiguration.java index 979b6057..52084ab3 100644 --- a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/HttpClientFeignLoadBalancerConfiguration.java +++ b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/HttpClientFeignLoadBalancerConfiguration.java @@ -63,7 +63,7 @@ class HttpClientFeignLoadBalancerConfiguration { public Client feignRetryClient(LoadBalancerClient loadBalancerClient, HttpClient httpClient, LoadBalancedRetryFactory loadBalancedRetryFactory) { ApacheHttpClient delegate = new ApacheHttpClient(httpClient); - return new RetryableBlockingFeignLoadBalancerClient(delegate, loadBalancerClient, loadBalancedRetryFactory); + return new RetryableFeignBlockingLoadBalancerClient(delegate, loadBalancerClient, loadBalancedRetryFactory); } } diff --git a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/OkHttpFeignLoadBalancerConfiguration.java b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/OkHttpFeignLoadBalancerConfiguration.java index d55fe8d6..0ead2e9b 100644 --- a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/OkHttpFeignLoadBalancerConfiguration.java +++ b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/OkHttpFeignLoadBalancerConfiguration.java @@ -62,7 +62,7 @@ class OkHttpFeignLoadBalancerConfiguration { public Client feignRetryClient(LoadBalancerClient loadBalancerClient, okhttp3.OkHttpClient okHttpClient, LoadBalancedRetryFactory loadBalancedRetryFactory) { OkHttpClient delegate = new OkHttpClient(okHttpClient); - return new RetryableBlockingFeignLoadBalancerClient(delegate, loadBalancerClient, loadBalancedRetryFactory); + return new RetryableFeignBlockingLoadBalancerClient(delegate, loadBalancerClient, loadBalancedRetryFactory); } } diff --git a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/RetryableBlockingFeignLoadBalancerClient.java b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/RetryableFeignBlockingLoadBalancerClient.java similarity index 98% rename from spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/RetryableBlockingFeignLoadBalancerClient.java rename to spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/RetryableFeignBlockingLoadBalancerClient.java index 1e9c6046..d844d361 100644 --- a/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/RetryableBlockingFeignLoadBalancerClient.java +++ b/spring-cloud-openfeign-core/src/main/java/org/springframework/cloud/openfeign/loadbalancer/RetryableFeignBlockingLoadBalancerClient.java @@ -57,7 +57,7 @@ import org.springframework.util.Assert; * @author Olga Maciaszek-Sharma * @since 2.2.6 */ -public class RetryableBlockingFeignLoadBalancerClient implements Client { +public class RetryableFeignBlockingLoadBalancerClient implements Client { private static final Log LOG = LogFactory.getLog(FeignBlockingLoadBalancerClient.class); @@ -67,7 +67,7 @@ public class RetryableBlockingFeignLoadBalancerClient implements Client { private final LoadBalancedRetryFactory loadBalancedRetryFactory; - public RetryableBlockingFeignLoadBalancerClient(Client delegate, LoadBalancerClient loadBalancerClient, + public RetryableFeignBlockingLoadBalancerClient(Client delegate, LoadBalancerClient loadBalancerClient, LoadBalancedRetryFactory loadBalancedRetryFactory) { this.delegate = delegate; this.loadBalancerClient = loadBalancerClient; diff --git a/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/FeignLoadBalancerAutoConfigurationTests.java b/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/FeignLoadBalancerAutoConfigurationTests.java index d3d1dc88..3c720848 100644 --- a/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/FeignLoadBalancerAutoConfigurationTests.java +++ b/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/FeignLoadBalancerAutoConfigurationTests.java @@ -104,8 +104,8 @@ class FeignLoadBalancerAutoConfigurationTests { } private void assertLoadBalancedWithRetries(ConfigurableApplicationContext context, Class delegateClass) { - Map retryableBeans = context - .getBeansOfType(RetryableBlockingFeignLoadBalancerClient.class); + Map retryableBeans = context + .getBeansOfType(RetryableFeignBlockingLoadBalancerClient.class); assertThat(retryableBeans).hasSize(1); Map beans = context .getBeansOfType(FeignBlockingLoadBalancerClient.class); diff --git a/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/RetryableBlockingFeignLoadBalancerClientTests.java b/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/RetryableFeignBlockingLoadBalancerClientTests.java similarity index 96% rename from spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/RetryableBlockingFeignLoadBalancerClientTests.java rename to spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/RetryableFeignBlockingLoadBalancerClientTests.java index 28b90d62..12d539af 100644 --- a/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/RetryableBlockingFeignLoadBalancerClientTests.java +++ b/spring-cloud-openfeign-core/src/test/java/org/springframework/cloud/openfeign/loadbalancer/RetryableFeignBlockingLoadBalancerClientTests.java @@ -52,17 +52,17 @@ import static org.mockito.Mockito.verify; import static org.mockito.Mockito.when; /** - * Tests for {@link RetryableBlockingFeignLoadBalancerClient}. Note: the underlying + * Tests for {@link RetryableFeignBlockingLoadBalancerClient}. Note: the underlying * {@link BlockingLoadBalancerClient} is already extensively tested in the Spring Cloud * Commons project, so here we are only testing the interactions between - * {@link RetryableBlockingFeignLoadBalancerClient} and its delegates. + * {@link RetryableFeignBlockingLoadBalancerClient} and its delegates. * * @see BlockingLoadBalancerClientTests * @author Olga Maciaszek-Sharma */ @ExtendWith(MockitoExtension.class) -class RetryableBlockingFeignLoadBalancerClientTests { +class RetryableFeignBlockingLoadBalancerClientTests { private Client delegate = mock(Client.class); @@ -72,7 +72,7 @@ class RetryableBlockingFeignLoadBalancerClientTests { private LoadBalancerProperties properties = new LoadBalancerProperties(); - private RetryableBlockingFeignLoadBalancerClient feignBlockingLoadBalancerClient = new RetryableBlockingFeignLoadBalancerClient( + private RetryableFeignBlockingLoadBalancerClient feignBlockingLoadBalancerClient = new RetryableFeignBlockingLoadBalancerClient( delegate, loadBalancerClient, retryFactory); private ServiceInstance serviceInstance = new DefaultServiceInstance("test-a", "test", "testhost", 80, false);