You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by gn...@apache.org on 2020/03/04 08:57:53 UTC
[camel] 08/32: Use AbstractReifier.createProcessor() when possible
This is an automated email from the ASF dual-hosted git repository.
gnodet pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d79fe4b7f46c782ed032c8b73d6d5c5d384456ae
Author: Guillaume Nodet <gn...@gmail.com>
AuthorDate: Tue Feb 25 14:42:25 2020 +0100
Use AbstractReifier.createProcessor() when possible
---
.../org/apache/camel/component/hystrix/processor/HystrixReifier.java | 2 +-
.../java/org/apache/camel/component/resilience4j/ResilienceReifier.java | 2 +-
.../java/org/apache/camel/reifier/InterceptSendToEndpointReifier.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixReifier.java b/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixReifier.java
index a67b314..524ce45 100644
--- a/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixReifier.java
+++ b/components/camel-hystrix/src/main/java/org/apache/camel/component/hystrix/processor/HystrixReifier.java
@@ -50,7 +50,7 @@ public class HystrixReifier extends ProcessorReifier<CircuitBreakerDefinition> {
Processor processor = createChildProcessor(true);
Processor fallback = null;
if (definition.getOnFallback() != null) {
- fallback = ProcessorReifier.reifier(route, definition.getOnFallback()).createProcessor();
+ fallback = createProcessor(definition.getOnFallback());
}
final HystrixConfigurationDefinition config = buildHystrixConfiguration();
diff --git a/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceReifier.java b/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceReifier.java
index ec0b35c..0d10156 100644
--- a/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceReifier.java
+++ b/components/camel-resilience4j/src/main/java/org/apache/camel/component/resilience4j/ResilienceReifier.java
@@ -50,7 +50,7 @@ public class ResilienceReifier extends ProcessorReifier<CircuitBreakerDefinition
Processor processor = createChildProcessor(true);
Processor fallback = null;
if (definition.getOnFallback() != null) {
- fallback = ProcessorReifier.reifier(route, definition.getOnFallback()).createProcessor();
+ fallback = createProcessor(definition.getOnFallback());
}
boolean fallbackViaNetwork = definition.getOnFallback() != null && parseBoolean(definition.getOnFallback().getFallbackViaNetwork(), false);
if (fallbackViaNetwork) {
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/InterceptSendToEndpointReifier.java b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/InterceptSendToEndpointReifier.java
index 9a6940a..93fa79a 100644
--- a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/InterceptSendToEndpointReifier.java
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/InterceptSendToEndpointReifier.java
@@ -53,7 +53,7 @@ public class InterceptSendToEndpointReifier extends ProcessorReifier<InterceptSe
// fallback to default implementation if factory did not create the
// processor
if (afterProcessor == null) {
- afterProcessor = reifier(route, to).createProcessor();
+ afterProcessor = createProcessor(to);
}
}
final Processor after = afterProcessor;