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 950da501..48af5c7b 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 @@ -58,7 +58,7 @@ class DefaultFeignLoadBalancerConfiguration { public Client feignRetryClient(BlockingLoadBalancerClient loadBalancerClient, List loadBalancedRetryFactories) { AnnotationAwareOrderComparator.sort(loadBalancedRetryFactories); - return new RetryableBlockingFeignLoadBalancerClient( + return new RetryableFeignBlockingLoadBalancerClient( new Client.Default(null, null), loadBalancerClient, loadBalancedRetryFactories.get(0)); } 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 75483e61..569bbbd9 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 @@ -69,7 +69,7 @@ class HttpClientFeignLoadBalancerConfiguration { List loadBalancedRetryFactories) { AnnotationAwareOrderComparator.sort(loadBalancedRetryFactories); ApacheHttpClient delegate = new ApacheHttpClient(httpClient); - return new RetryableBlockingFeignLoadBalancerClient(delegate, loadBalancerClient, + return new RetryableFeignBlockingLoadBalancerClient(delegate, loadBalancerClient, loadBalancedRetryFactories.get(0)); } 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 0179d35f..cac08b5f 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 @@ -68,7 +68,7 @@ class OkHttpFeignLoadBalancerConfiguration { List loadBalancedRetryFactories) { AnnotationAwareOrderComparator.sort(loadBalancedRetryFactories); OkHttpClient delegate = new OkHttpClient(okHttpClient); - return new RetryableBlockingFeignLoadBalancerClient(delegate, loadBalancerClient, + return new RetryableFeignBlockingLoadBalancerClient(delegate, loadBalancerClient, loadBalancedRetryFactories.get(0)); } 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 3931311d..07319c31 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 @@ -54,7 +54,7 @@ import org.springframework.retry.support.RetryTemplate; * @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); @@ -65,7 +65,7 @@ public class RetryableBlockingFeignLoadBalancerClient implements Client { private final LoadBalancedRetryFactory loadBalancedRetryFactory; - public RetryableBlockingFeignLoadBalancerClient(Client delegate, + public RetryableFeignBlockingLoadBalancerClient(Client delegate, BlockingLoadBalancerClient loadBalancerClient, LoadBalancedRetryFactory loadBalancedRetryFactory) { this.delegate = delegate; 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 ca540972..72b29925 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 @@ -139,8 +139,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 7d5d2e9f..00c6c456 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); @@ -73,7 +73,7 @@ class RetryableBlockingFeignLoadBalancerClientTests { private LoadBalancerRetryProperties properties = new LoadBalancerRetryProperties(); - private RetryableBlockingFeignLoadBalancerClient feignBlockingLoadBalancerClient = new RetryableBlockingFeignLoadBalancerClient( + private RetryableFeignBlockingLoadBalancerClient feignBlockingLoadBalancerClient = new RetryableFeignBlockingLoadBalancerClient( delegate, loadBalancerClient, retryFactory); private ServiceInstance serviceInstance = new DefaultServiceInstance("test-a", "test",