fix PolarisRouterServiceInstanceListSupplier npe with reactivefeign

pull/926/head
seanyu 3 years ago
parent 4e37401baa
commit 1a29c3f23a

@ -97,12 +97,14 @@ public class PolarisRouterServiceInstanceListSupplier extends DelegatingServiceI
PolarisRouterContext routerContext = null; PolarisRouterContext routerContext = null;
DefaultRequestContext requestContext = (DefaultRequestContext) request.getContext(); DefaultRequestContext requestContext = (DefaultRequestContext) request.getContext();
if (requestContext instanceof RequestDataContext) { if (requestContext != null) {
routerContext = buildRouterContext(((RequestDataContext) requestContext).getClientRequest().getHeaders()); if (requestContext instanceof RequestDataContext) {
} routerContext = buildRouterContext(((RequestDataContext) requestContext).getClientRequest().getHeaders());
else if (requestContext.getClientRequest() instanceof PolarisLoadBalancerRequest) { }
routerContext = buildRouterContext(((PolarisLoadBalancerRequest<?>) requestContext.getClientRequest()).getRequest() else if (requestContext.getClientRequest() instanceof PolarisLoadBalancerRequest) {
.getHeaders()); routerContext = buildRouterContext(((PolarisLoadBalancerRequest<?>) requestContext.getClientRequest()).getRequest()
.getHeaders());
}
} }
if (routerContext == null) { if (routerContext == null) {

Loading…
Cancel
Save