This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7be118a50aa336cbe43ba846d815493fce2d53df Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Sat Jan 25 10:00:43 2020 +0100 CAMEL-14438: camel-core - Optimize core for checking for stop routing --- .../camel/component/hystrix/processor/HystrixProcessorCommand.java | 2 +- .../org/apache/camel/component/resilience4j/ResilienceProcessor.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixProcessorCommand.java b/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixProcessorCommand.java index dced5c4..2569082 100644 --- a/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixProcessorCommand.java +++ b/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixProcessorCommand.java @@ -84,7 +84,7 @@ public class HystrixProcessorCommand extends HystrixCommand { // give the rest of the pipeline another chance exchange.setProperty(Exchange.EXCEPTION_HANDLED, true); exchange.setProperty(Exchange.EXCEPTION_CAUGHT, exception); - exchange.removeProperty(Exchange.ROUTE_STOP); + exchange.setRouteStop(false); exchange.setException(null); // and we should not be regarded as exhausted as we are in a try .. catch block exchange.removeProperty(Exchange.REDELIVERY_EXHAUSTED); diff --git a/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceProcessor.java b/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceProcessor.java index 6be5c9d..587c6ab 100644 --- a/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceProcessor.java +++ b/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceProcessor.java @@ -479,7 +479,7 @@ public class ResilienceProcessor extends AsyncProcessorSupport implements CamelC // give the rest of the pipeline another chance exchange.setProperty(Exchange.EXCEPTION_HANDLED, true); exchange.setProperty(Exchange.EXCEPTION_CAUGHT, exchange.getException()); - exchange.removeProperty(Exchange.ROUTE_STOP); + exchange.setRouteStop(false); exchange.setException(null); // and we should not be regarded as exhausted as we are in a try .. // catch block