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 <[email protected]> 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;
