diff --git a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/ReactorLoadBalancerExchangeFilterFunction.java b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/ReactorLoadBalancerExchangeFilterFunction.java index ef599eff0..0ae705590 100644 --- a/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/ReactorLoadBalancerExchangeFilterFunction.java +++ b/spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/ReactorLoadBalancerExchangeFilterFunction.java @@ -80,11 +80,15 @@ public Mono filter(ClientRequest request, ExchangeFunction next) 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> choose(String serviceId) { ReactiveLoadBalancer loadBalancer = loadBalancerFactory .getInstance(serviceId);