Skip to content

Commit b85f737

Browse files
timothymathisonspencergibb
authored andcommitted
Adds reconstructURI method to ReactorLoadBalancerExchangeFilterFunction
fixes gh-711
1 parent 289d1db commit b85f737

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

spring-cloud-commons/src/main/java/org/springframework/cloud/client/loadbalancer/reactive/ReactorLoadBalancerExchangeFilterFunction.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -80,11 +80,15 @@ public Mono<ClientResponse> filter(ClientRequest request, ExchangeFunction next)
8080
serviceId, instance.getUri()));
8181
}
8282
ClientRequest newRequest = buildClientRequest(request,
83-
LoadBalancerUriTools.reconstructURI(instance, originalUrl));
83+
reconstructURI(instance, originalUrl));
8484
return next.exchange(newRequest);
8585
});
8686
}
8787

88+
protected URI reconstructURI(ServiceInstance instance, URI original) {
89+
return LoadBalancerUriTools.reconstructURI(instance, original);
90+
}
91+
8892
protected Mono<Response<ServiceInstance>> choose(String serviceId) {
8993
ReactiveLoadBalancer<ServiceInstance> loadBalancer = loadBalancerFactory
9094
.getInstance(serviceId);

0 commit comments

Comments
 (0)