Class RetryAwareServiceInstanceListSupplier

java.lang.Object

org.springframework.cloud.loadbalancer.core.DelegatingServiceInstanceListSupplier

org.springframework.cloud.loadbalancer.core.RetryAwareServiceInstanceListSupplier

All Implemented Interfaces:

Supplier<reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>>, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, SelectedInstanceCallback, ServiceInstanceListSupplier

public class RetryAwareServiceInstanceListSupplier
extends DelegatingServiceInstanceListSupplier

A ServiceInstanceListSupplier implementation that avoids picking the same service instance while retrying requests.

Since:

3.0.0

Author:

Olga Maciaszek-Sharma

Field Summary

Fields inherited from class DelegatingServiceInstanceListSupplier

delegate

Constructor Summary

Constructors

Constructor	Description
RetryAwareServiceInstanceListSupplier(ServiceInstanceListSupplier delegate)

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>	get()
reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>>	get(org.springframework.cloud.client.loadbalancer.Request request)
String	getServiceId()

Methods inherited from class DelegatingServiceInstanceListSupplier

afterPropertiesSet, destroy, getDelegate, selectedServiceInstance

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RetryAwareServiceInstanceListSupplier

public RetryAwareServiceInstanceListSupplier(ServiceInstanceListSupplier delegate)

Method Details

getServiceId

public String getServiceId()

Specified by:

getServiceId in interface ServiceInstanceListSupplier

Overrides:

getServiceId in class DelegatingServiceInstanceListSupplier

get

public reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>> get(org.springframework.cloud.client.loadbalancer.Request request)

get

public reactor.core.publisher.Flux<List<org.springframework.cloud.client.ServiceInstance>> get()