diff --git a/fizz-core/src/main/java/we/filter/AggregateFilter.java b/fizz-core/src/main/java/we/filter/AggregateFilter.java index af82024..1aa5f18 100644 --- a/fizz-core/src/main/java/we/filter/AggregateFilter.java +++ b/fizz-core/src/main/java/we/filter/AggregateFilter.java @@ -82,11 +82,6 @@ public class AggregateFilter implements WebFilter { @Override public Mono filter(ServerWebExchange exchange, WebFilterChain chain) { - FilterResult pfr = WebUtils.getPrevFilterResult(exchange); - if (!pfr.success) { - return WebUtils.getDirectResponse(exchange); - } - String serviceId = WebUtils.getBackendService(exchange); if (serviceId == null) { return chain.filter(exchange); @@ -106,6 +101,11 @@ public class AggregateFilter implements WebFilter { } } + FilterResult pfr = WebUtils.getPrevFilterResult(exchange); + if (!pfr.success) { + return WebUtils.getDirectResponse(exchange); + } + long start = System.currentTimeMillis(); ServerHttpRequest request = exchange.getRequest(); ServerHttpResponse serverHttpResponse = exchange.getResponse(); diff --git a/fizz-core/src/main/java/we/filter/FilterExceptionHandlerConfig.java b/fizz-core/src/main/java/we/filter/FilterExceptionHandlerConfig.java index bdcfb82..1e37bda 100644 --- a/fizz-core/src/main/java/we/filter/FilterExceptionHandlerConfig.java +++ b/fizz-core/src/main/java/we/filter/FilterExceptionHandlerConfig.java @@ -96,7 +96,7 @@ public class FilterExceptionHandlerConfig { } } Mono vm; - Object fc = exchange.getAttributes().get(WebUtils.FILTER_CONTEXT); + Object fc = exchange.getAttribute(WebUtils.FILTER_CONTEXT); if (fc == null) { // t came from flow control filter StringBuilder b = ThreadContext.getStringBuilder(); WebUtils.request2stringBuilder(exchange, b);