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

Reply via email to