fix PolarisRouterServiceInstanceListSupplier npe with reactivefeign

pull/927/head
seanyu 3 years ago
parent 323cf3b3f6
commit 94164ea55f

@ -97,6 +97,7 @@ public class PolarisRouterServiceInstanceListSupplier extends DelegatingServiceI
PolarisRouterContext routerContext = null;
DefaultRequestContext requestContext = (DefaultRequestContext) request.getContext();
if (requestContext != null) {
if (requestContext instanceof RequestDataContext) {
routerContext = buildRouterContext(((RequestDataContext) requestContext).getClientRequest().getHeaders());
}
@ -104,6 +105,7 @@ public class PolarisRouterServiceInstanceListSupplier extends DelegatingServiceI
routerContext = buildRouterContext(((PolarisLoadBalancerRequest<?>) requestContext.getClientRequest()).getRequest()
.getHeaders());
}
}
if (routerContext == null) {
// return all servers if router context is null.

Loading…
Cancel
Save