fix: fix PolarisRouterServiceInstanceListSupplier npe with reactive feign (#925)

Shanyou Yu (Sean Yu) 3 years ago committed by seanyu
parent 8b9968216d
commit 2a70b0e950

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

Loading…
Cancel
Save