Adds reconstructURI method to ReactorLoadBalancerExchangeFilterFunction

fixes gh-711
This commit is contained in:
Timothy
2020-03-15 19:11:23 -05:00
committed by Spencer Gibb
parent 289d1dbae5
commit b85f7375d1

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);