You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2020/01/25 09:09:45 UTC
[camel] 02/03: CAMEL-14438: camel-core - Optimize core for checking
for stop routing
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 <cl...@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