Merge branch '2.2.x'

This commit is contained in:
Spencer Gibb
2020-03-16 15:43:28 -04:00

View File

@@ -80,11 +80,15 @@ public class ReactorLoadBalancerExchangeFilterFunction implements ExchangeFilter
serviceId, instance.getUri()));
}
ClientRequest newRequest = buildClientRequest(request,
LoadBalancerUriTools.reconstructURI(instance, originalUrl));
reconstructURI(instance, originalUrl));
return next.exchange(newRequest);
});
}
protected URI reconstructURI(ServiceInstance instance, URI original) {
return LoadBalancerUriTools.reconstructURI(instance, original);
}
protected Mono<Response<ServiceInstance>> choose(String serviceId) {
ReactiveLoadBalancer<ServiceInstance> loadBalancer = loadBalancerFactory
.getInstance(serviceId);