Bumping versions
This commit is contained in:
@@ -54,9 +54,8 @@ public class RandomLoadBalancer implements ReactorServiceInstanceLoadBalancer {
|
||||
public RandomLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider,
|
||||
String serviceId) {
|
||||
this.serviceId = serviceId;
|
||||
this.serviceInstanceListSingletonSupplier = SingletonSupplier.of(
|
||||
() -> serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new)
|
||||
);
|
||||
this.serviceInstanceListSingletonSupplier = SingletonSupplier
|
||||
.of(() -> serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new));
|
||||
}
|
||||
|
||||
@SuppressWarnings("rawtypes")
|
||||
|
||||
@@ -69,9 +69,8 @@ public class RoundRobinLoadBalancer implements ReactorServiceInstanceLoadBalance
|
||||
public RoundRobinLoadBalancer(ObjectProvider<ServiceInstanceListSupplier> serviceInstanceListSupplierProvider,
|
||||
String serviceId, int seedPosition) {
|
||||
this.serviceId = serviceId;
|
||||
this.serviceInstanceListSingletonSupplier = SingletonSupplier.of(
|
||||
() -> serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new)
|
||||
);
|
||||
this.serviceInstanceListSingletonSupplier = SingletonSupplier
|
||||
.of(() -> serviceInstanceListSupplierProvider.getIfAvailable(NoopServiceInstanceListSupplier::new));
|
||||
this.position = new AtomicInteger(seedPosition);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user