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 2025/01/20 08:46:32 UTC
(camel) branch main updated: InheritErrorHandler (#16853)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new e571a5ac212 InheritErrorHandler (#16853)
e571a5ac212 is described below
commit e571a5ac21233ded4f8c26422118cb9bc96ca142
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Mon Jan 20 09:46:26 2025 +0100
InheritErrorHandler (#16853)
* CAMEL-21630: camel-core - InheritErrorHandler should only be for failover LB and CircuitBreaker and internally only for camel-jta
---
.../camel/catalog/models/circuitBreaker.json | 9 +-
.../camel/catalog/models/failoverLoadBalancer.json | 3 +-
.../apache/camel/catalog/models/loadBalance.json | 3 +-
.../apache/camel/catalog/schemas/camel-spring.xsd | 25 +-
.../SpringInheritErrorHandlerDefaultTest.java | 30 --
.../SpringInheritErrorHandlerFalseTest.java | 30 --
.../SpringInheritErrorHandlerTrueTest.java | 30 --
.../FailOverLoadBalanceAutoStartupFalseTest.xml | 4 +-
.../processor/InheritErrorHandlerDefaultTest.xml | 48 ---
.../processor/InheritErrorHandlerFalseTest.xml | 48 ---
.../processor/InheritErrorHandlerTrueTest.xml | 48 ---
.../org/apache/camel/model/circuitBreaker.json | 9 +-
.../org/apache/camel/model/loadBalance.json | 3 +-
.../model/loadbalancer/failoverLoadBalancer.json | 3 +-
.../camel/model/CircuitBreakerDefinition.java | 28 ++
.../apache/camel/model/LoadBalanceDefinition.java | 2 +-
.../apache/camel/model/OnExceptionDefinition.java | 4 -
.../apache/camel/model/ProcessorDefinition.java | 48 +--
.../camel/model/RouteTemplateDefinition.java | 1 -
.../FailoverLoadBalancerDefinition.java | 20 +
.../apache/camel/reifier/LoadBalanceReifier.java | 2 +-
.../org/apache/camel/reifier/ProcessorReifier.java | 2 +-
.../processor/InheritErrorHandlerDefaultTest.java | 66 ----
.../processor/InheritErrorHandlerFalseTest.java | 73 ----
.../processor/InheritErrorHandlerTrueTest.java | 66 ----
.../java/org/apache/camel/xml/in/ModelParser.java | 3 +-
.../java/org/apache/camel/xml/out/ModelWriter.java | 3 +-
.../org/apache/camel/yaml/out/ModelWriter.java | 3 +-
.../ROOT/pages/camel-4x-upgrade-guide-4_10.adoc | 23 ++
.../dsl/yaml/deserializers/ModelDeserializers.java | 440 +--------------------
.../generated/resources/schema/camelYamlDsl.json | 5 -
.../camel/maven/packaging/SchemaGeneratorMojo.java | 7 -
32 files changed, 145 insertions(+), 944 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/circuitBreaker.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/circuitBreaker.json
index a08dc83a16c..575c3a45fbf 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/circuitBreaker.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/circuitBreaker.json
@@ -16,10 +16,11 @@
"description": { "index": 1, "kind": "attribute", "displayName": "Description", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the description of this node" },
"disabled": { "index": 2, "kind": "attribute", "displayName": "Disabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime." },
"configuration": { "index": 3, "kind": "attribute", "displayName": "Configuration", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Refers to a circuit breaker configuration (such as resillience4j, or microprofile-fault-tolerance) to use for configuring the circuit breaker EIP." },
- "resilience4jConfiguration": { "index": 4, "kind": "element", "displayName": "Resilience4j Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.Resilience4jConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use Resilience4j with the given configuration." },
- "faultToleranceConfiguration": { "index": 5, "kind": "element", "displayName": "Fault Tolerance Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.FaultToleranceConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use MicroProfile Fault Tolerance with the given configuration." },
- "onFallback": { "index": 6, "kind": "element", "displayName": "On Fallback", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.OnFallbackDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "The fallback route path to execute that does not go over the network. This should be a static or cached result that can immediately be returned upon failure. If the fallback requires network connection then use onFallbackV [...]
- "outputs": { "index": 7, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
+ "inheritErrorHandler": { "index": 4, "kind": "attribute", "displayName": "Inherit Error Handler", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "To turn on or off Camel error handling during circuit breaker. If this is enabled then Camel error handler will first trigger if there is an error in the circuit breaker, which all [...]
+ "resilience4jConfiguration": { "index": 5, "kind": "element", "displayName": "Resilience4j Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.Resilience4jConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use Resilience4j with the given configuration." },
+ "faultToleranceConfiguration": { "index": 6, "kind": "element", "displayName": "Fault Tolerance Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.FaultToleranceConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use MicroProfile Fault Tolerance with the given configuration." },
+ "onFallback": { "index": 7, "kind": "element", "displayName": "On Fallback", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.OnFallbackDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "The fallback route path to execute that does not go over the network. This should be a static or cached result that can immediately be returned upon failure. If the fallback requires network connection then use onFallbackV [...]
+ "outputs": { "index": 8, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
},
"exchangeProperties": {
"CamelResponseSuccessfulExecution": { "index": 0, "kind": "exchangeProperty", "displayName": "Response Successful Execution", "label": "producer", "required": false, "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "description": "Whether the exchange was processed successfully by the circuit breaker" },
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/failoverLoadBalancer.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/failoverLoadBalancer.json
index 7121ecf7dfd..e0bc89dd7ad 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/failoverLoadBalancer.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/failoverLoadBalancer.json
@@ -16,6 +16,7 @@
"exception": { "index": 1, "kind": "element", "displayName": "Exception", "group": "common", "required": false, "type": "array", "javaType": "java.util.List<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "description": "A list of class names for specific exceptions to monitor. If no exceptions are configured then all exceptions are monitored" },
"roundRobin": { "index": 2, "kind": "attribute", "displayName": "Round Robin", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Whether or not the failover load balancer should operate in round robin mode or not. If not, then it will always start from the first endpoint when a new message is to be processed. In other words it restart from the top for every message. If roun [...]
"sticky": { "index": 3, "kind": "attribute", "displayName": "Sticky", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Whether or not the failover load balancer should operate in sticky mode or not. If not, then it will always start from the first endpoint when a new message is to be processed. In other words it restart from the top for every message. If sticky is enabled, [...]
- "maximumFailoverAttempts": { "index": 4, "kind": "attribute", "displayName": "Maximum Failover Attempts", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "A value to indicate after X failover attempts we should exhaust (give up). Use -1 to indicate never give up and continuously try to failover. Use 0 to never failover. And use e.g. 3 to failover at m [...]
+ "maximumFailoverAttempts": { "index": 4, "kind": "attribute", "displayName": "Maximum Failover Attempts", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "A value to indicate after X failover attempts we should exhaust (give up). Use -1 to indicate never give up and continuously try to failover. Use 0 to never failover. And use e.g. 3 to failover at m [...]
+ "inheritErrorHandler": { "index": 5, "kind": "attribute", "displayName": "Inherit Error Handler", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "To turn off Camel error handling during load balancing. By default, Camel error handler will attempt calling a service, which means you can specify retires and other fine-grained se [...]
}
}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/loadBalance.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/loadBalance.json
index 9a164dfebc9..3dc530c798a 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/loadBalance.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/loadBalance.json
@@ -16,7 +16,6 @@
"description": { "index": 1, "kind": "attribute", "displayName": "Description", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the description of this node" },
"disabled": { "index": 2, "kind": "attribute", "displayName": "Disabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime." },
"loadBalancerType": { "index": 3, "kind": "element", "displayName": "Load Balancer Type", "group": "common", "required": true, "type": "object", "javaType": "org.apache.camel.model.LoadBalancerDefinition", "oneOf": [ "customLoadBalancer", "failoverLoadBalancer", "randomLoadBalancer", "roundRobinLoadBalancer", "stickyLoadBalancer", "topicLoadBalancer", "weightedLoadBalancer" ], "deprecated": false, "autowired": false, "secret": false, "description": "The load balancer to be used" },
- "outputs": { "index": 4, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
- "inheritErrorHandler": { "index": 5, "kind": "attribute", "displayName": "Inherit Error Handler", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether or not to inherit the configured error handler. The default value is true. You can use this to disable using the inherited error handler for a given DSL such as a load [...]
+ "outputs": { "index": 4, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
}
}
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
index d90060852aa..7b650d74165 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
@@ -3574,7 +3574,6 @@ later at runtime. Default value: false
</xs:documentation>
</xs:annotation>
</xs:attribute>
- <xs:attribute name="inheritErrorHandler" type="xs:boolean"/>
</xs:extension>
</xs:complexContent>
</xs:complexType>
@@ -4709,6 +4708,18 @@ runtime. Default value: false
<![CDATA[
Refers to a circuit breaker configuration (such as resillience4j, or microprofile-fault-tolerance) to use for
configuring the circuit breaker EIP.
+]]>
+ </xs:documentation>
+ </xs:annotation>
+ </xs:attribute>
+ <xs:attribute name="inheritErrorHandler" type="xs:boolean">
+ <xs:annotation>
+ <xs:documentation xml:lang="en">
+<![CDATA[
+To turn on or off Camel error handling during circuit breaker. If this is enabled then Camel error handler will first
+trigger if there is an error in the circuit breaker, which allows to let Camel handle redeliveries. If all attempts is
+failed, then after the circuit breaker is finished, then Camel error handler can handle the error as well such as the
+dead letter channel. By default, Camel error handler is turned off. Default value: false
]]>
</xs:documentation>
</xs:annotation>
@@ -7135,6 +7146,18 @@ balancing (instead of using the next when starting).
A value to indicate after X failover attempts we should exhaust (give up). Use -1 to indicate never give up and
continuously try to failover. Use 0 to never failover. And use e.g. 3 to failover at most 3 times before giving up. This
option can be used whether roundRobin is enabled or not. Default value: -1
+]]>
+ </xs:documentation>
+ </xs:annotation>
+ </xs:attribute>
+ <xs:attribute name="inheritErrorHandler" type="xs:boolean">
+ <xs:annotation>
+ <xs:documentation xml:lang="en">
+<![CDATA[
+To turn off Camel error handling during load balancing. By default, Camel error handler will attempt calling a service,
+which means you can specify retires and other fine-grained settings. And only when Camel error handler have failed all
+attempts, then this load balancer will fail over to the next endpoint and try again. You can turn this off, and then
+this load balancer will fail over immediately on an error. Default value: true
]]>
</xs:documentation>
</xs:annotation>
diff --git a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerDefaultTest.java b/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerDefaultTest.java
deleted file mode 100644
index 2e8fdfe306c..00000000000
--- a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerDefaultTest.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.spring.processor;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.processor.InheritErrorHandlerDefaultTest;
-
-import static org.apache.camel.spring.processor.SpringTestHelper.createSpringCamelContext;
-
-public class SpringInheritErrorHandlerDefaultTest extends InheritErrorHandlerDefaultTest {
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- return createSpringCamelContext(this, "org/apache/camel/spring/processor/InheritErrorHandlerDefaultTest.xml");
- }
-}
diff --git a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerFalseTest.java b/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerFalseTest.java
deleted file mode 100644
index e4f18abff5b..00000000000
--- a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerFalseTest.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.spring.processor;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.processor.InheritErrorHandlerFalseTest;
-
-import static org.apache.camel.spring.processor.SpringTestHelper.createSpringCamelContext;
-
-public class SpringInheritErrorHandlerFalseTest extends InheritErrorHandlerFalseTest {
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- return createSpringCamelContext(this, "org/apache/camel/spring/processor/InheritErrorHandlerFalseTest.xml");
- }
-}
diff --git a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerTrueTest.java b/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerTrueTest.java
deleted file mode 100644
index 60c8126e1c3..00000000000
--- a/components/camel-spring-xml/src/test/java/org/apache/camel/spring/processor/SpringInheritErrorHandlerTrueTest.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.spring.processor;
-
-import org.apache.camel.CamelContext;
-import org.apache.camel.processor.InheritErrorHandlerTrueTest;
-
-import static org.apache.camel.spring.processor.SpringTestHelper.createSpringCamelContext;
-
-public class SpringInheritErrorHandlerTrueTest extends InheritErrorHandlerTrueTest {
-
- @Override
- protected CamelContext createCamelContext() throws Exception {
- return createSpringCamelContext(this, "org/apache/camel/spring/processor/InheritErrorHandlerTrueTest.xml");
- }
-}
diff --git a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/FailOverLoadBalanceAutoStartupFalseTest.xml b/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/FailOverLoadBalanceAutoStartupFalseTest.xml
index 31436ab5713..98c80256c74 100644
--- a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/FailOverLoadBalanceAutoStartupFalseTest.xml
+++ b/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/FailOverLoadBalanceAutoStartupFalseTest.xml
@@ -29,8 +29,8 @@
<route id="foo" autoStartup="false">
<from uri="direct:start"/>
- <loadBalance inheritErrorHandler="true">
- <failoverLoadBalancer maximumFailoverAttempts="3" roundRobin="true"/>
+ <loadBalance>
+ <failoverLoadBalancer maximumFailoverAttempts="3" roundRobin="true" inheritErrorHandler="true"/>
<to uri="direct:x"/>
<to uri="direct:y"/>
<to uri="direct:z"/>
diff --git a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerDefaultTest.xml b/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerDefaultTest.xml
deleted file mode 100644
index a2d52f7d2a1..00000000000
--- a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerDefaultTest.xml
+++ /dev/null
@@ -1,48 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
- ">
-
- <bean id="errorHandler" class="org.apache.camel.builder.LegacyDeadLetterChannelBuilder">
- <property name="deadLetterUri" value="mock:dead"/>
- <property name="redeliveryPolicy" ref="myPolicy"/>
- </bean>
-
- <bean id="myPolicy" class="org.apache.camel.processor.errorhandler.RedeliveryPolicy">
- <property name="maximumRedeliveries" value="2"/>
- <property name="redeliveryDelay" value="0"/>
- </bean>
-
- <bean id="myProcessor" class="org.apache.camel.processor.InheritErrorHandlerDefaultTest$MyProcessor"/>
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <jmxAgent id="jmx" disabled="true"/>
- <route errorHandlerRef="errorHandler">
- <from uri="direct:start"/>
- <process ref="myProcessor"/>
- <to uri="mock:result"/>
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerFalseTest.xml b/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerFalseTest.xml
deleted file mode 100644
index cbd51ba1413..00000000000
--- a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerFalseTest.xml
+++ /dev/null
@@ -1,48 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
- ">
-
- <bean id="errorHandler" class="org.apache.camel.builder.LegacyDeadLetterChannelBuilder">
- <property name="deadLetterUri" value="mock:dead"/>
- <property name="redeliveryPolicy" ref="myPolicy"/>
- </bean>
-
- <bean id="myPolicy" class="org.apache.camel.processor.errorhandler.RedeliveryPolicy">
- <property name="maximumRedeliveries" value="2"/>
- <property name="redeliveryDelay" value="0"/>
- </bean>
-
- <bean id="myProcessor" class="org.apache.camel.processor.InheritErrorHandlerFalseTest$MyProcessor"/>
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <jmxAgent id="jmx" disabled="true"/>
- <route errorHandlerRef="errorHandler">
- <from uri="direct:start"/>
- <process ref="myProcessor" inheritErrorHandler="false"/>
- <to uri="mock:result"/>
- </route>
- </camelContext>
-
-</beans>
diff --git a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerTrueTest.xml b/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerTrueTest.xml
deleted file mode 100644
index 82c0c893c98..00000000000
--- a/components/camel-spring-xml/src/test/resources/org/apache/camel/spring/processor/InheritErrorHandlerTrueTest.xml
+++ /dev/null
@@ -1,48 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-
- Licensed to the Apache Software Foundation (ASF) under one or more
- contributor license agreements. See the NOTICE file distributed with
- this work for additional information regarding copyright ownership.
- The ASF licenses this file to You under the Apache License, Version 2.0
- (the "License"); you may not use this file except in compliance with
- the License. You may obtain a copy of the License at
-
- http://www.apache.org/licenses/LICENSE-2.0
-
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
-
--->
-<beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="
- http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
- http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
- ">
-
- <bean id="errorHandler" class="org.apache.camel.builder.LegacyDeadLetterChannelBuilder">
- <property name="deadLetterUri" value="mock:dead"/>
- <property name="redeliveryPolicy" ref="myPolicy"/>
- </bean>
-
- <bean id="myPolicy" class="org.apache.camel.processor.errorhandler.RedeliveryPolicy">
- <property name="maximumRedeliveries" value="2"/>
- <property name="redeliveryDelay" value="0"/>
- </bean>
-
- <bean id="myProcessor" class="org.apache.camel.processor.InheritErrorHandlerTrueTest$MyProcessor"/>
-
- <camelContext xmlns="http://camel.apache.org/schema/spring">
- <jmxAgent id="jmx" disabled="true"/>
- <route errorHandlerRef="errorHandler">
- <from uri="direct:start"/>
- <process ref="myProcessor" inheritErrorHandler="true"/>
- <to uri="mock:result"/>
- </route>
- </camelContext>
-
-</beans>
diff --git a/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/circuitBreaker.json b/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/circuitBreaker.json
index a08dc83a16c..575c3a45fbf 100644
--- a/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/circuitBreaker.json
+++ b/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/circuitBreaker.json
@@ -16,10 +16,11 @@
"description": { "index": 1, "kind": "attribute", "displayName": "Description", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the description of this node" },
"disabled": { "index": 2, "kind": "attribute", "displayName": "Disabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime." },
"configuration": { "index": 3, "kind": "attribute", "displayName": "Configuration", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Refers to a circuit breaker configuration (such as resillience4j, or microprofile-fault-tolerance) to use for configuring the circuit breaker EIP." },
- "resilience4jConfiguration": { "index": 4, "kind": "element", "displayName": "Resilience4j Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.Resilience4jConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use Resilience4j with the given configuration." },
- "faultToleranceConfiguration": { "index": 5, "kind": "element", "displayName": "Fault Tolerance Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.FaultToleranceConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use MicroProfile Fault Tolerance with the given configuration." },
- "onFallback": { "index": 6, "kind": "element", "displayName": "On Fallback", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.OnFallbackDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "The fallback route path to execute that does not go over the network. This should be a static or cached result that can immediately be returned upon failure. If the fallback requires network connection then use onFallbackV [...]
- "outputs": { "index": 7, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
+ "inheritErrorHandler": { "index": 4, "kind": "attribute", "displayName": "Inherit Error Handler", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "To turn on or off Camel error handling during circuit breaker. If this is enabled then Camel error handler will first trigger if there is an error in the circuit breaker, which all [...]
+ "resilience4jConfiguration": { "index": 5, "kind": "element", "displayName": "Resilience4j Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.Resilience4jConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use Resilience4j with the given configuration." },
+ "faultToleranceConfiguration": { "index": 6, "kind": "element", "displayName": "Fault Tolerance Configuration", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.FaultToleranceConfigurationDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "Configures the circuit breaker to use MicroProfile Fault Tolerance with the given configuration." },
+ "onFallback": { "index": 7, "kind": "element", "displayName": "On Fallback", "group": "common", "required": false, "type": "object", "javaType": "org.apache.camel.model.OnFallbackDefinition", "deprecated": false, "autowired": false, "secret": false, "description": "The fallback route path to execute that does not go over the network. This should be a static or cached result that can immediately be returned upon failure. If the fallback requires network connection then use onFallbackV [...]
+ "outputs": { "index": 8, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
},
"exchangeProperties": {
"CamelResponseSuccessfulExecution": { "index": 0, "kind": "exchangeProperty", "displayName": "Response Successful Execution", "label": "producer", "required": false, "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "description": "Whether the exchange was processed successfully by the circuit breaker" },
diff --git a/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadBalance.json b/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadBalance.json
index 9a164dfebc9..3dc530c798a 100644
--- a/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadBalance.json
+++ b/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadBalance.json
@@ -16,7 +16,6 @@
"description": { "index": 1, "kind": "attribute", "displayName": "Description", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Sets the description of this node" },
"disabled": { "index": 2, "kind": "attribute", "displayName": "Disabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime." },
"loadBalancerType": { "index": 3, "kind": "element", "displayName": "Load Balancer Type", "group": "common", "required": true, "type": "object", "javaType": "org.apache.camel.model.LoadBalancerDefinition", "oneOf": [ "customLoadBalancer", "failoverLoadBalancer", "randomLoadBalancer", "roundRobinLoadBalancer", "stickyLoadBalancer", "topicLoadBalancer", "weightedLoadBalancer" ], "deprecated": false, "autowired": false, "secret": false, "description": "The load balancer to be used" },
- "outputs": { "index": 4, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
- "inheritErrorHandler": { "index": 5, "kind": "attribute", "displayName": "Inherit Error Handler", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Sets whether or not to inherit the configured error handler. The default value is true. You can use this to disable using the inherited error handler for a given DSL such as a load [...]
+ "outputs": { "index": 4, "kind": "element", "displayName": "Outputs", "group": "common", "required": true, "type": "array", "javaType": "java.util.List", "oneOf": [ "aggregate", "bean", "choice", "circuitBreaker", "claimCheck", "convertBodyTo", "convertHeaderTo", "convertVariableTo", "delay", "doCatch", "doFinally", "doTry", "dynamicRouter", "enrich", "filter", "idempotentConsumer", "intercept", "interceptFrom", "interceptSendToEndpoint", "kamelet", "loadBalance", "log", "loop", "mar [...]
}
}
diff --git a/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadbalancer/failoverLoadBalancer.json b/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadbalancer/failoverLoadBalancer.json
index 7121ecf7dfd..e0bc89dd7ad 100644
--- a/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadbalancer/failoverLoadBalancer.json
+++ b/core/camel-core-model/src/generated/resources/META-INF/org/apache/camel/model/loadbalancer/failoverLoadBalancer.json
@@ -16,6 +16,7 @@
"exception": { "index": 1, "kind": "element", "displayName": "Exception", "group": "common", "required": false, "type": "array", "javaType": "java.util.List<java.lang.String>", "deprecated": false, "autowired": false, "secret": false, "description": "A list of class names for specific exceptions to monitor. If no exceptions are configured then all exceptions are monitored" },
"roundRobin": { "index": 2, "kind": "attribute", "displayName": "Round Robin", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Whether or not the failover load balancer should operate in round robin mode or not. If not, then it will always start from the first endpoint when a new message is to be processed. In other words it restart from the top for every message. If roun [...]
"sticky": { "index": 3, "kind": "attribute", "displayName": "Sticky", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "description": "Whether or not the failover load balancer should operate in sticky mode or not. If not, then it will always start from the first endpoint when a new message is to be processed. In other words it restart from the top for every message. If sticky is enabled, [...]
- "maximumFailoverAttempts": { "index": 4, "kind": "attribute", "displayName": "Maximum Failover Attempts", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "A value to indicate after X failover attempts we should exhaust (give up). Use -1 to indicate never give up and continuously try to failover. Use 0 to never failover. And use e.g. 3 to failover at m [...]
+ "maximumFailoverAttempts": { "index": 4, "kind": "attribute", "displayName": "Maximum Failover Attempts", "group": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "-1", "description": "A value to indicate after X failover attempts we should exhaust (give up). Use -1 to indicate never give up and continuously try to failover. Use 0 to never failover. And use e.g. 3 to failover at m [...]
+ "inheritErrorHandler": { "index": 5, "kind": "attribute", "displayName": "Inherit Error Handler", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "To turn off Camel error handling during load balancing. By default, Camel error handler will attempt calling a service, which means you can specify retires and other fine-grained se [...]
}
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/CircuitBreakerDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/CircuitBreakerDefinition.java
index e43ffb3adf4..7d420c92b02 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/CircuitBreakerDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/CircuitBreakerDefinition.java
@@ -39,6 +39,9 @@ public class CircuitBreakerDefinition extends OutputDefinition<CircuitBreakerDef
@XmlAttribute
private String configuration;
+ @XmlAttribute
+ @Metadata(label = "advanced", javaType = "java.lang.Boolean", defaultValue = "false")
+ private Boolean inheritErrorHandler;
@XmlElement
private Resilience4jConfigurationDefinition resilience4jConfiguration;
@XmlElement
@@ -52,6 +55,7 @@ public class CircuitBreakerDefinition extends OutputDefinition<CircuitBreakerDef
protected CircuitBreakerDefinition(CircuitBreakerDefinition source) {
super(source);
this.configuration = source.configuration;
+ this.inheritErrorHandler = source.inheritErrorHandler;
this.resilience4jConfiguration
= source.resilience4jConfiguration != null ? source.resilience4jConfiguration.copyDefinition() : null;
this.faultToleranceConfiguration
@@ -127,6 +131,16 @@ public class CircuitBreakerDefinition extends OutputDefinition<CircuitBreakerDef
this.configuration = configuration;
}
+ @Override
+ public Boolean getInheritErrorHandler() {
+ return inheritErrorHandler;
+ }
+
+ @Override
+ public void setInheritErrorHandler(Boolean inheritErrorHandler) {
+ this.inheritErrorHandler = inheritErrorHandler;
+ }
+
public OnFallbackDefinition getOnFallback() {
return onFallback;
}
@@ -183,6 +197,20 @@ public class CircuitBreakerDefinition extends OutputDefinition<CircuitBreakerDef
return this;
}
+ /**
+ * To turn on or off Camel error handling during circuit breaker.
+ *
+ * If this is enabled then Camel error handler will first trigger if there is an error in the circuit breaker, which
+ * allows to let Camel handle redeliveries. If all attempts is failed, then after the circuit breaker is finished,
+ * then Camel error handler can handle the error as well such as the dead letter channel.
+ *
+ * By default, Camel error handler is turned off.
+ */
+ public CircuitBreakerDefinition inheritErrorHandler(boolean inheritErrorHandler) {
+ this.inheritErrorHandler = inheritErrorHandler;
+ return this;
+ }
+
/**
* The fallback route path to execute that does <b>not</b> go over the network.
* <p>
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java
index 76e010032ac..1a280ce8f48 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/LoadBalanceDefinition.java
@@ -172,8 +172,8 @@ public class LoadBalanceDefinition extends OutputDefinition<LoadBalanceDefinitio
def.setMaximumFailoverAttempts(Integer.toString(maximumFailoverAttempts));
def.setRoundRobin(Boolean.toString(roundRobin));
def.setSticky(Boolean.toString(sticky));
+ def.setInheritErrorHandler(inheritErrorHandler);
setLoadBalancerType(def);
- this.setInheritErrorHandler(inheritErrorHandler);
return this;
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java
index 4e8bf850637..c4f39860076 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/OnExceptionDefinition.java
@@ -175,10 +175,6 @@ public class OnExceptionDefinition extends OutputDefinition<OnExceptionDefinitio
}
public void validateConfiguration() {
- if (isInheritErrorHandler() != null && isInheritErrorHandler()) {
- throw new IllegalArgumentException(this + " cannot have the inheritErrorHandler option set to true");
- }
-
if (exceptions == null || exceptions.isEmpty()) {
throw new IllegalArgumentException("At least one exception must be configured on " + this);
}
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/ProcessorDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/ProcessorDefinition.java
index ae630e0ef09..eb9c0cf2c41 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/ProcessorDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/ProcessorDefinition.java
@@ -85,9 +85,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
@XmlAttribute
@Metadata(label = "advanced", javaType = "java.lang.Boolean")
protected String disabled;
- @XmlAttribute
- @Metadata(label = "advanced", javaType = "java.lang.Boolean")
- protected Boolean inheritErrorHandler;
@XmlTransient
private final Deque<Block> blocks = new LinkedList<>();
@XmlTransient
@@ -98,6 +95,8 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
private final List<InterceptStrategy> interceptStrategies = new ArrayList<>();
@XmlTransient
private final int index;
+ @XmlTransient
+ private Boolean inheritErrorHandler; // used for camel-jta
protected ProcessorDefinition() {
// every time we create a definition we should inc the counter
@@ -107,7 +106,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
protected ProcessorDefinition(ProcessorDefinition source) {
super(source);
this.disabled = source.disabled;
- this.inheritErrorHandler = source.inheritErrorHandler;
this.blocks.addAll(source.blocks);
this.parent = source.parent;
this.routeConfiguration = source.routeConfiguration;
@@ -4142,32 +4140,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
return asType();
}
- /**
- * Sets whether or not to inherit the configured error handler. <br/>
- * The default value is <tt>true</tt>.
- * <p/>
- * You can use this to disable using the inherited error handler for a given DSL such as a load balancer where you
- * want to use a custom error handler strategy.
- *
- * @param inheritErrorHandler whether to not to inherit the error handler for this node
- * @return the builder
- */
- public Type inheritErrorHandler(boolean inheritErrorHandler) {
- // set on last output
- int size = getOutputs().size();
- if (size == 0) {
- // if no outputs then configure this DSL
- setInheritErrorHandler(inheritErrorHandler);
- } else {
- // configure on last output as its the intended
- ProcessorDefinition<?> output = getOutputs().get(size - 1);
- if (output != null) {
- output.setInheritErrorHandler(inheritErrorHandler);
- }
- }
- return asType();
- }
-
@SuppressWarnings("unchecked")
Type asType() {
return (Type) this;
@@ -4313,14 +4285,6 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
this.interceptStrategies.add(strategy);
}
- public Boolean isInheritErrorHandler() {
- return inheritErrorHandler;
- }
-
- public void setInheritErrorHandler(Boolean inheritErrorHandler) {
- this.inheritErrorHandler = inheritErrorHandler;
- }
-
@Override
public String getDisabled() {
return disabled;
@@ -4331,6 +4295,14 @@ public abstract class ProcessorDefinition<Type extends ProcessorDefinition<Type>
this.disabled = disabled;
}
+ public Boolean getInheritErrorHandler() {
+ return inheritErrorHandler;
+ }
+
+ public void setInheritErrorHandler(Boolean inheritErrorHandler) {
+ this.inheritErrorHandler = inheritErrorHandler;
+ }
+
/**
* Returns a label to describe this node such as the expression if some kind of expression node
*/
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplateDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplateDefinition.java
index 0a02ccd2303..aca502d6311 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplateDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/RouteTemplateDefinition.java
@@ -425,7 +425,6 @@ public class RouteTemplateDefinition extends OptionalIdentifiedDefinition<RouteT
copy.setAutoStartup(route.getAutoStartup());
copy.setDelayer(route.getDelayer());
copy.setGroup(route.getGroup());
- copy.setInheritErrorHandler(route.isInheritErrorHandler());
// make a defensive copy of the input as input can be adviced during testing or other changes
copy.setInput(route.getInput().copy());
copy.setInputType(route.getInputType());
diff --git a/core/camel-core-model/src/main/java/org/apache/camel/model/loadbalancer/FailoverLoadBalancerDefinition.java b/core/camel-core-model/src/main/java/org/apache/camel/model/loadbalancer/FailoverLoadBalancerDefinition.java
index 9c70e700f57..4075965a28c 100644
--- a/core/camel-core-model/src/main/java/org/apache/camel/model/loadbalancer/FailoverLoadBalancerDefinition.java
+++ b/core/camel-core-model/src/main/java/org/apache/camel/model/loadbalancer/FailoverLoadBalancerDefinition.java
@@ -49,6 +49,9 @@ public class FailoverLoadBalancerDefinition extends LoadBalancerDefinition {
@XmlAttribute
@Metadata(defaultValue = "-1")
private String maximumFailoverAttempts;
+ @XmlAttribute
+ @Metadata(label = "advanced", javaType = "java.lang.Boolean", defaultValue = "true")
+ private Boolean inheritErrorHandler;
public FailoverLoadBalancerDefinition() {
}
@@ -60,6 +63,7 @@ public class FailoverLoadBalancerDefinition extends LoadBalancerDefinition {
this.roundRobin = source.roundRobin;
this.sticky = source.sticky;
this.maximumFailoverAttempts = source.maximumFailoverAttempts;
+ this.inheritErrorHandler = source.inheritErrorHandler;
}
@Override
@@ -136,6 +140,22 @@ public class FailoverLoadBalancerDefinition extends LoadBalancerDefinition {
this.maximumFailoverAttempts = maximumFailoverAttempts;
}
+ public Boolean getInheritErrorHandler() {
+ return inheritErrorHandler;
+ }
+
+ /**
+ * To turn off Camel error handling during load balancing.
+ * <p/>
+ * By default, Camel error handler will attempt calling a service, which means you can specify retires and other
+ * fine-grained settings. And only when Camel error handler have failed all attempts, then this load balancer will
+ * fail over to the next endpoint and try again. You can turn this off, and then this load balancer will fail over
+ * immediately on an error.
+ */
+ public void setInheritErrorHandler(Boolean inheritErrorHandler) {
+ this.inheritErrorHandler = inheritErrorHandler;
+ }
+
@Override
public String toString() {
return "FailoverLoadBalancer";
diff --git a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/LoadBalanceReifier.java b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/LoadBalanceReifier.java
index 95404bf3073..308ca41c3f8 100644
--- a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/LoadBalanceReifier.java
+++ b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/LoadBalanceReifier.java
@@ -58,7 +58,7 @@ public class LoadBalanceReifier extends ProcessorReifier<LoadBalanceDefinition>
loadBalancer.addProcessor(channel);
}
- Boolean inherit = definition.isInheritErrorHandler();
+ Boolean inherit = definition.getInheritErrorHandler();
if (definition.getLoadBalancerType() instanceof FailoverLoadBalancerDefinition) {
// special for failover load balancer where you can configure it to
// not inherit error handler for its children
diff --git a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/ProcessorReifier.java b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/ProcessorReifier.java
index 6fd8d4bdd53..8df133008ff 100644
--- a/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/ProcessorReifier.java
+++ b/core/camel-core-reifier/src/main/java/org/apache/camel/reifier/ProcessorReifier.java
@@ -650,7 +650,7 @@ public abstract class ProcessorReifier<T extends ProcessorDefinition<?>> extends
}
protected Channel wrapChannel(Processor processor, ProcessorDefinition<?> child) throws Exception {
- return wrapChannel(processor, child, definition.isInheritErrorHandler());
+ return wrapChannel(processor, child, definition.getInheritErrorHandler());
}
protected Channel wrapChannel(Processor processor, ProcessorDefinition<?> child, Boolean inheritErrorHandler)
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerDefaultTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerDefaultTest.java
deleted file mode 100644
index c8332ac6a7d..00000000000
--- a/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerDefaultTest.java
+++ /dev/null
@@ -1,66 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.processor;
-
-import org.apache.camel.ContextTestSupport;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class InheritErrorHandlerDefaultTest extends ContextTestSupport {
-
- private static int counter;
-
- @Test
- public void testInheritErrorHandlerDefault() throws Exception {
- counter = 0;
-
- getMockEndpoint("mock:result").expectedMessageCount(0);
- getMockEndpoint("mock:dead").expectedMessageCount(1);
-
- template.sendBody("direct:start", "Hello World");
-
- assertMockEndpointsSatisfied();
-
- assertEquals(3, counter);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public void configure() {
- errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(2).redeliveryDelay(0));
-
- from("direct:start").process(new MyProcessor()).to("mock:result");
- }
- };
- }
-
- public static class MyProcessor implements Processor {
-
- @Override
- public void process(Exchange exchange) {
- counter++;
- exchange.setException(new IllegalArgumentException("Damn"));
- }
- }
-
-}
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerFalseTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerFalseTest.java
deleted file mode 100644
index b8c4ea4899e..00000000000
--- a/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerFalseTest.java
+++ /dev/null
@@ -1,73 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.processor;
-
-import org.apache.camel.ContextTestSupport;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.fail;
-
-public class InheritErrorHandlerFalseTest extends ContextTestSupport {
-
- private static int counter;
-
- @Test
- public void testInheritErrorHandlerFalse() throws Exception {
- counter = 0;
-
- getMockEndpoint("mock:result").expectedMessageCount(0);
- getMockEndpoint("mock:dead").expectedMessageCount(0);
-
- try {
- template.sendBody("direct:start", "Hello World");
- fail("Should throw exception");
- } catch (Exception e) {
- IllegalArgumentException iae = assertIsInstanceOf(IllegalArgumentException.class, e.getCause());
- assertEquals("Damn", iae.getMessage());
- }
-
- assertMockEndpointsSatisfied();
-
- assertEquals(1, counter);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public void configure() {
- errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(2));
-
- from("direct:start").process(new MyProcessor()).inheritErrorHandler(false).to("mock:result");
- }
- };
- }
-
- public static class MyProcessor implements Processor {
-
- @Override
- public void process(Exchange exchange) {
- counter++;
- exchange.setException(new IllegalArgumentException("Damn"));
- }
- }
-
-}
diff --git a/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerTrueTest.java b/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerTrueTest.java
deleted file mode 100644
index e5b40ba872d..00000000000
--- a/core/camel-core/src/test/java/org/apache/camel/processor/InheritErrorHandlerTrueTest.java
+++ /dev/null
@@ -1,66 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.processor;
-
-import org.apache.camel.ContextTestSupport;
-import org.apache.camel.Exchange;
-import org.apache.camel.Processor;
-import org.apache.camel.builder.RouteBuilder;
-import org.junit.jupiter.api.Test;
-
-import static org.junit.jupiter.api.Assertions.assertEquals;
-
-public class InheritErrorHandlerTrueTest extends ContextTestSupport {
-
- private static int counter;
-
- @Test
- public void testInheritErrorHandlerTrue() throws Exception {
- counter = 0;
-
- getMockEndpoint("mock:result").expectedMessageCount(0);
- getMockEndpoint("mock:dead").expectedMessageCount(1);
-
- template.sendBody("direct:start", "Hello World");
-
- assertMockEndpointsSatisfied();
-
- assertEquals(3, counter);
- }
-
- @Override
- protected RouteBuilder createRouteBuilder() {
- return new RouteBuilder() {
- @Override
- public void configure() {
- errorHandler(deadLetterChannel("mock:dead").maximumRedeliveries(2).redeliveryDelay(0));
-
- from("direct:start").process(new MyProcessor()).inheritErrorHandler(true).to("mock:result");
- }
- };
- }
-
- public static class MyProcessor implements Processor {
-
- @Override
- public void process(Exchange exchange) {
- counter++;
- exchange.setException(new IllegalArgumentException("Damn"));
- }
- }
-
-}
diff --git a/core/camel-xml-io/src/generated/java/org/apache/camel/xml/in/ModelParser.java b/core/camel-xml-io/src/generated/java/org/apache/camel/xml/in/ModelParser.java
index 76114a816cc..6b289389e57 100644
--- a/core/camel-xml-io/src/generated/java/org/apache/camel/xml/in/ModelParser.java
+++ b/core/camel-xml-io/src/generated/java/org/apache/camel/xml/in/ModelParser.java
@@ -140,7 +140,6 @@ public class ModelParser extends BaseParser {
protected <T extends ProcessorDefinition> AttributeHandler<T> processorDefinitionAttributeHandler() {
return (def, key, val) -> switch (key) {
case "disabled": def.setDisabled(val); yield true;
- case "inheritErrorHandler": def.setInheritErrorHandler(Boolean.valueOf(val)); yield true;
default: yield optionalIdentifiedDefinitionAttributeHandler().accept(def, key, val);
};
}
@@ -247,6 +246,7 @@ public class ModelParser extends BaseParser {
protected CircuitBreakerDefinition doParseCircuitBreakerDefinition() throws IOException, XmlPullParserException {
return doParse(new CircuitBreakerDefinition(), (def, key, val) -> switch (key) {
case "configuration": def.setConfiguration(val); yield true;
+ case "inheritErrorHandler": def.setInheritErrorHandler(Boolean.valueOf(val)); yield true;
default: yield processorDefinitionAttributeHandler().accept(def, key, val);
}, (def, key) -> switch (key) {
case "faultToleranceConfiguration": def.setFaultToleranceConfiguration(doParseFaultToleranceConfigurationDefinition()); yield true;
@@ -2495,6 +2495,7 @@ public class ModelParser extends BaseParser {
}
protected FailoverLoadBalancerDefinition doParseFailoverLoadBalancerDefinition() throws IOException, XmlPullParserException {
return doParse(new FailoverLoadBalancerDefinition(), (def, key, val) -> switch (key) {
+ case "inheritErrorHandler": def.setInheritErrorHandler(Boolean.valueOf(val)); yield true;
case "maximumFailoverAttempts": def.setMaximumFailoverAttempts(val); yield true;
case "roundRobin": def.setRoundRobin(val); yield true;
case "sticky": def.setSticky(val); yield true;
diff --git a/core/camel-xml-io/src/generated/java/org/apache/camel/xml/out/ModelWriter.java b/core/camel-xml-io/src/generated/java/org/apache/camel/xml/out/ModelWriter.java
index eec84356568..931fc47b8b3 100644
--- a/core/camel-xml-io/src/generated/java/org/apache/camel/xml/out/ModelWriter.java
+++ b/core/camel-xml-io/src/generated/java/org/apache/camel/xml/out/ModelWriter.java
@@ -888,6 +888,7 @@ public class ModelWriter extends BaseWriter {
protected void doWriteCircuitBreakerDefinition(String name, CircuitBreakerDefinition def) throws IOException {
startElement(name);
doWriteProcessorDefinitionAttributes(def);
+ doWriteAttribute("inheritErrorHandler", toString(def.getInheritErrorHandler()), "false");
doWriteAttribute("configuration", def.getConfiguration(), null);
doWriteElement("resilience4jConfiguration", def.getResilience4jConfiguration(), this::doWriteResilience4jConfigurationDefinition);
doWriteElement("onFallback", def.getOnFallback(), this::doWriteOnFallbackDefinition);
@@ -1384,7 +1385,6 @@ public class ModelWriter extends BaseWriter {
}
protected void doWriteProcessorDefinitionAttributes(ProcessorDefinition<?> def) throws IOException {
doWriteOptionalIdentifiedDefinitionAttributes(def);
- doWriteAttribute("inheritErrorHandler", toString(def.isInheritErrorHandler()), null);
doWriteAttribute("disabled", def.getDisabled(), null);
}
protected void doWriteProcessorDefinition(String name, ProcessorDefinition<?> def) throws IOException {
@@ -3267,6 +3267,7 @@ public class ModelWriter extends BaseWriter {
protected void doWriteFailoverLoadBalancerDefinition(String name, FailoverLoadBalancerDefinition def) throws IOException {
startElement(name);
doWriteIdentifiedTypeAttributes(def);
+ doWriteAttribute("inheritErrorHandler", toString(def.getInheritErrorHandler()), "true");
doWriteAttribute("sticky", def.getSticky(), null);
doWriteAttribute("maximumFailoverAttempts", def.getMaximumFailoverAttempts(), "-1");
doWriteAttribute("roundRobin", def.getRoundRobin(), null);
diff --git a/core/camel-yaml-io/src/generated/java/org/apache/camel/yaml/out/ModelWriter.java b/core/camel-yaml-io/src/generated/java/org/apache/camel/yaml/out/ModelWriter.java
index 5bdbf977472..a4aa07d8b4e 100644
--- a/core/camel-yaml-io/src/generated/java/org/apache/camel/yaml/out/ModelWriter.java
+++ b/core/camel-yaml-io/src/generated/java/org/apache/camel/yaml/out/ModelWriter.java
@@ -888,6 +888,7 @@ public class ModelWriter extends BaseWriter {
protected void doWriteCircuitBreakerDefinition(String name, CircuitBreakerDefinition def) throws IOException {
startElement(name);
doWriteProcessorDefinitionAttributes(def);
+ doWriteAttribute("inheritErrorHandler", toString(def.getInheritErrorHandler()), "false");
doWriteAttribute("configuration", def.getConfiguration(), null);
doWriteElement("resilience4jConfiguration", def.getResilience4jConfiguration(), this::doWriteResilience4jConfigurationDefinition);
doWriteElement("onFallback", def.getOnFallback(), this::doWriteOnFallbackDefinition);
@@ -1384,7 +1385,6 @@ public class ModelWriter extends BaseWriter {
}
protected void doWriteProcessorDefinitionAttributes(ProcessorDefinition<?> def) throws IOException {
doWriteOptionalIdentifiedDefinitionAttributes(def);
- doWriteAttribute("inheritErrorHandler", toString(def.isInheritErrorHandler()), null);
doWriteAttribute("disabled", def.getDisabled(), null);
}
protected void doWriteProcessorDefinition(String name, ProcessorDefinition<?> def) throws IOException {
@@ -3267,6 +3267,7 @@ public class ModelWriter extends BaseWriter {
protected void doWriteFailoverLoadBalancerDefinition(String name, FailoverLoadBalancerDefinition def) throws IOException {
startElement(name);
doWriteIdentifiedTypeAttributes(def);
+ doWriteAttribute("inheritErrorHandler", toString(def.getInheritErrorHandler()), "true");
doWriteAttribute("sticky", def.getSticky(), null);
doWriteAttribute("maximumFailoverAttempts", def.getMaximumFailoverAttempts(), "-1");
doWriteAttribute("roundRobin", def.getRoundRobin(), null);
diff --git a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_10.adoc b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_10.adoc
index 6e59ed317be..463885eff88 100644
--- a/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_10.adoc
+++ b/docs/user-manual/modules/ROOT/pages/camel-4x-upgrade-guide-4_10.adoc
@@ -65,6 +65,29 @@ Should now be:
</circuitBreaker>
----
+And `inheritErrorHandler` has been moved from `<loadBalance>` to `<failoverLoadBalancer` which
+is the only load balancer support this option.
+
+For example:
+
+[source,xml]
+----
+ <loadBalance inheritErrorHandler="true">
+ <failoverLoadBalancer maximumFailoverAttempts="3" roundRobin="true"/>
+ ...
+ </loadBalance>
+----
+
+Should now be:
+
+[source,xml]
+----
+ <loadBalance>
+ <failoverLoadBalancer maximumFailoverAttempts="3" roundRobin="true" inheritErrorHandler="true"/>
+ ...
+ </loadBalance>
+----
+
=== camel-azure-files
The class `org.apache.camel.component.file.azure.FilesHeaders` has been renamed to `org.apache.camel.component.file.azure.FilesConstants`.
diff --git a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java
index 38aae8eb0f2..aefab1977f5 100644
--- a/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java
+++ b/dsl/camel-yaml-dsl/camel-yaml-dsl-deserializers/src/generated/java/org/apache/camel/dsl/yaml/deserializers/ModelDeserializers.java
@@ -361,7 +361,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "forceCompletionOnStop", type = "boolean", description = "Indicates to complete all current aggregated exchanges when the context is stopped", displayName = "Force Completion On Stop"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidCorrelationKeys", type = "boolean", description = "If a correlation key cannot be successfully evaluated it will be ignored by logging a DEBUG and then just ignore the incoming Exchange.", displayName = "Ignore Invalid Correlation Keys"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "optimisticLockRetryPolicy", type = "object:org.apache.camel.model.OptimisticLockRetryPolicyDefinition", description = "Allows to configure retry settings when using optimistic locking.", displayName = "Optimistic Lock Retry Policy"),
@YamlProperty(name = "optimisticLocking", type = "boolean", description = "Turns on using optimistic locking, which requires the aggregationRepository being used, is supporting this by implementing org.apache.camel.spi.OptimisticLockingAggregationRepository .", displayName = "Optimistic Locking"),
@YamlProperty(name = "parallelProcessing", type = "boolean", description = "When aggregated are completed they are being send out of the aggregator. This option indicates whether or not Camel should use a thread pool with multiple threads for concurrency. If no custom thread pool has been specified then Camel creates a default pool with 10 concurrent threads.", displayName = "Parallel Processing"),
@@ -504,11 +503,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidCorrelationKeys(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "optimisticLockRetryPolicy": {
org.apache.camel.model.OptimisticLockRetryPolicyDefinition val = asType(node, org.apache.camel.model.OptimisticLockRetryPolicyDefinition.class);
target.setOptimisticLockRetryPolicyDefinition(val);
@@ -1108,7 +1102,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "method", type = "string", description = "Sets the method name on the bean to use", displayName = "Method"),
@YamlProperty(name = "ref", type = "string", description = "Sets a reference to an existing bean to use, which is looked up from the registry", displayName = "Ref"),
@YamlProperty(name = "scope", type = "enum:Singleton,Request,Prototype", defaultValue = "Singleton", description = "Scope of bean. When using singleton scope (default) the bean is created or looked up only once and reused for the lifetime of the endpoint. The bean should be thread-safe in case concurrent threads is calling the bean at the same time. When using request scope the bean is created or looked up once per request (exchange). This can be used if you want to s [...]
@@ -1144,11 +1137,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "method": {
String val = asText(node);
target.setMethod(val);
@@ -1913,7 +1901,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "exception", type = "array:string", description = "The exception(s) to catch.", displayName = "Exception"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onWhen", type = "object:org.apache.camel.model.OnWhenDefinition", description = "Used for triggering doCatch in specific situations", displayName = "On When"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
@@ -1943,11 +1930,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExceptions(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onWhen": {
org.apache.camel.model.OnWhenDefinition val = asType(node, org.apache.camel.model.OnWhenDefinition.class);
target.setOnWhen(val);
@@ -1986,7 +1968,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "otherwise", type = "object:org.apache.camel.model.OtherwiseDefinition", description = "Sets the otherwise node", displayName = "Otherwise"),
@YamlProperty(name = "precondition", type = "boolean", description = "Indicates whether this Choice EIP is in precondition mode or not. If so its branches (when/otherwise) are evaluated during startup to keep at runtime only the branch that matched.", displayName = "Precondition"),
@YamlProperty(name = "when", type = "array:org.apache.camel.model.WhenDefinition", description = "Sets the when nodes", displayName = "When")
@@ -2012,11 +1993,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "otherwise": {
org.apache.camel.model.OtherwiseDefinition val = asType(node, org.apache.camel.model.OtherwiseDefinition.class);
target.setOtherwise(val);
@@ -2066,7 +2042,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "faultToleranceConfiguration", type = "object:org.apache.camel.model.FaultToleranceConfigurationDefinition", description = "Configures the circuit breaker to use MicroProfile Fault Tolerance with the given configuration.", displayName = "Fault Tolerance Configuration"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
+ @YamlProperty(name = "inheritErrorHandler", type = "boolean", description = "To turn on or off Camel error handling during circuit breaker. If this is enabled then Camel error handler will first trigger if there is an error in the circuit breaker, which allows to let Camel handle redeliveries. If all attempts is failed, then after the circuit breaker is finished, then Camel error handler can handle the error as well such as the dead letter channel. By default, Camel e [...]
@YamlProperty(name = "onFallback", type = "object:org.apache.camel.model.OnFallbackDefinition", description = "The fallback route path to execute that does not go over the network. This should be a static or cached result that can immediately be returned upon failure. If the fallback requires network connection then use onFallbackViaNetwork() .", displayName = "On Fallback"),
@YamlProperty(name = "resilience4jConfiguration", type = "object:org.apache.camel.model.Resilience4jConfigurationDefinition", description = "Configures the circuit breaker to use Resilience4j with the given configuration.", displayName = "Resilience4j Configuration"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
@@ -2156,7 +2132,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "filter", type = "string", description = "Specify a filter to control what data gets merged data back from the claim check repository. The following syntax is supported: body - to aggregate the message body attachments - to aggregate all the message attachments headers - to aggregate all the message headers header:pattern - to aggregate all the message headers that matches the pattern. The following pattern rules are applied in this order: exact m [...]
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "key", type = "string", description = "To use a specific key for claim check id (for dynamic keys use simple language syntax as the key).", displayName = "Key"),
@YamlProperty(name = "operation", type = "enum:Get,GetAndRemove,Set,Push,Pop", description = "The claim check operation to use. The following operations are supported: Get - Gets (does not remove) the claim check by the given key. GetAndRemove - Gets and removes the claim check by the given key. Set - Sets a new (will override if key already exists) claim check with the given key. Push - Sets a new claim check on the stack (does not use key). Pop - Gets the latest cla [...]
}
@@ -2196,11 +2171,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setFilter(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "key": {
String val = asText(node);
target.setKey(val);
@@ -2708,7 +2678,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "mandatory", type = "boolean", description = "When mandatory then the conversion must return a value (cannot be null), if this is not possible then NoTypeConversionAvailableException is thrown. Setting this to false could mean conversion is not possible and the value is null.", displayName = "Mandatory"),
@YamlProperty(name = "type", type = "string", required = true, description = "The java type to convert to", displayName = "Type")
}
@@ -2743,11 +2712,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "mandatory": {
String val = asText(node);
target.setMandatory(val);
@@ -2791,7 +2755,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "mandatory", type = "boolean", description = "When mandatory then the conversion must return a value (cannot be null), if this is not possible then NoTypeConversionAvailableException is thrown. Setting this to false could mean conversion is not possible and the value is null.", displayName = "Mandatory"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of message header to convert its value The simple language can be used to define a dynamic evaluated header name to be used. Otherwise a constant name will be used.", displayName = "Name"),
@YamlProperty(name = "toName", type = "string", description = "To use another header to store the result. By default, the result is stored in the same header. This option allows to use another header. The simple language can be used to define a dynamic evaluated header name to be used. Otherwise a constant name will be used.", displayName = "To Name"),
@@ -2823,11 +2786,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "mandatory": {
String val = asText(node);
target.setMandatory(val);
@@ -2881,7 +2839,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "mandatory", type = "boolean", description = "When mandatory then the conversion must return a value (cannot be null), if this is not possible then NoTypeConversionAvailableException is thrown. Setting this to false could mean conversion is not possible and the value is null.", displayName = "Mandatory"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of variable to convert its value The simple language can be used to define a dynamic evaluated header name to be used. Otherwise a constant name will be used.", displayName = "Name"),
@YamlProperty(name = "toName", type = "string", description = "To use another variable to store the result. By default, the result is stored in the same variable. This option allows to use another variable. The simple language can be used to define a dynamic evaluated variable name to be used. Otherwise a constant name will be used.", displayName = "To Name"),
@@ -2913,11 +2870,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "mandatory": {
String val = asText(node);
target.setMandatory(val);
@@ -4793,8 +4745,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "executorService", type = "string", description = "To use a custom Thread Pool if asyncDelay has been enabled.", displayName = "Executor Service"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to define how long time to wait (in millis)", displayName = "Expression", oneOf = "expression"),
- @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean")
+ @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id")
}
)
public static class DelayDefinitionDeserializer extends YamlDeserializerBase<DelayDefinition> {
@@ -4837,11 +4788,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -5105,7 +5051,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to call that returns the endpoint(s) to route to in the dynamic routing. Important: The expression will be called in a while loop fashion, until the expression returns null which means the dynamic router is finished.", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidEndpoints", type = "boolean", description = "Ignore the invalidate endpoint exception when try to create a producer with that endpoint", displayName = "Ignore Invalid Endpoints"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "uriDelimiter", type = "string", defaultValue = ",", description = "Sets the uri delimiter to use", displayName = "Uri Delimiter")
}
)
@@ -5144,11 +5089,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidEndpoints(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "uriDelimiter": {
String val = asText(node);
target.setUriDelimiter(val);
@@ -5314,7 +5254,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression that computes the endpoint uri to use as the resource endpoint to enrich from", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidEndpoint", type = "boolean", description = "Ignore the invalidate endpoint exception when try to create a producer with that endpoint", displayName = "Ignore Invalid Endpoint"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "shareUnitOfWork", type = "boolean", description = "Shares the org.apache.camel.spi.UnitOfWork with the parent and the resource exchange. Enrich will by default not share unit of work between the parent exchange and the resource exchange. This means the resource exchange has its own individual unit of work.", displayName = "Share Unit Of Work"),
@YamlProperty(name = "variableReceive", type = "string", description = "To use a variable as the source for the message body to send. This makes it handy to use variables for user data and to easily control what data to use for sending and receiving. Important: When using send variable then the message body is taken from this variable instead of the current message, however the headers from the message will still be used as well. In other words, the variable is used i [...]
@YamlProperty(name = "variableSend", type = "string", description = "To use a variable to store the received message body (only body, not headers). This makes it handy to use variables for user data and to easily control what data to use for sending and receiving. Important: When using receive variable then the received body is stored only in this variable and not on the current message.", displayName = "Variable Send")
@@ -5385,11 +5324,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidEndpoint(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "shareUnitOfWork": {
String val = asText(node);
target.setShareUnitOfWork(val);
@@ -5597,6 +5531,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
properties = {
@YamlProperty(name = "exception", type = "array:string", description = "A list of class names for specific exceptions to monitor. If no exceptions are configured then all exceptions are monitored", displayName = "Exception"),
@YamlProperty(name = "id", type = "string", description = "The id of this node", displayName = "Id"),
+ @YamlProperty(name = "inheritErrorHandler", type = "boolean", description = "To turn off Camel error handling during load balancing. By default, Camel error handler will attempt calling a service, which means you can specify retires and other fine-grained settings. And only when Camel error handler have failed all attempts, then this load balancer will fail over to the next endpoint and try again. You can turn this off, and then this load balancer will fail over immed [...]
@YamlProperty(name = "maximumFailoverAttempts", type = "string", defaultValue = "-1", description = "A value to indicate after X failover attempts we should exhaust (give up). Use -1 to indicate never give up and continuously try to failover. Use 0 to never failover. And use e.g. 3 to failover at most 3 times before giving up. This option can be used whether roundRobin is enabled or not.", displayName = "Maximum Failover Attempts"),
@YamlProperty(name = "roundRobin", type = "string", description = "Whether or not the failover load balancer should operate in round robin mode or not. If not, then it will always start from the first endpoint when a new message is to be processed. In other words it restart from the top for every message. If round robin is enabled, then it keeps state and will continue with the next endpoint in a round robin fashion. You can also enable sticky mode together with round [...]
@YamlProperty(name = "sticky", type = "string", description = "Whether or not the failover load balancer should operate in sticky mode or not. If not, then it will always start from the first endpoint when a new message is to be processed. In other words it restart from the top for every message. If sticky is enabled, then it keeps state and will continue with the last known good endpoint. You can also enable sticky mode together with round robin, if so then it will p [...]
@@ -5627,6 +5562,11 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setId(val);
break;
}
+ case "inheritErrorHandler": {
+ String val = asText(node);
+ target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
+ break;
+ }
case "maximumFailoverAttempts": {
String val = asText(node);
target.setMaximumFailoverAttempts(val);
@@ -6083,7 +6023,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to determine if the message should be filtered or not. If the expression returns an empty value or false then the message is filtered (dropped), otherwise the message is continued being routed.", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "statusPropertyName", type = "string", description = "Name of exchange property to use for storing the status of the filtering. Setting this allows to know if the filter predicate evaluated as true or false.", displayName = "Status Property Name"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
@@ -6113,11 +6052,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "statusPropertyName": {
String val = asText(node);
target.setStatusPropertyName(val);
@@ -6168,7 +6102,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
)
@@ -6192,11 +6125,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -7250,7 +7178,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression used to calculate the correlation key to use for duplicate check. The Exchange which has the same correlation key is regarded as a duplicate and will be rejected.", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "idempotentRepository", type = "string", required = true, description = "Sets the reference name of the message id repository", displayName = "Idempotent Repository"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "removeOnFailure", type = "boolean", description = "Sets whether to remove or keep the key on failure. The default behavior is to remove the key on failure.", displayName = "Remove On Failure"),
@YamlProperty(name = "skipDuplicate", type = "boolean", description = "Sets whether to skip duplicates or not. The default behavior is to skip duplicates. A duplicate message would have the Exchange property org.apache.camel.Exchange#DUPLICATE_MESSAGE set to a Boolean#TRUE value. A none duplicate message will not have this property set.", displayName = "Skip Duplicate"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
@@ -7296,11 +7223,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIdempotentRepository(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "removeOnFailure": {
String val = asText(node);
target.setRemoveOnFailure(val);
@@ -7414,7 +7336,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onWhen", type = "object:org.apache.camel.model.OnWhenDefinition", description = "To use an expression to only trigger intercepting in specific situations", displayName = "On When"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
@@ -7439,11 +7360,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onWhen": {
org.apache.camel.model.OnWhenDefinition val = asType(node, org.apache.camel.model.OnWhenDefinition.class);
target.setOnWhen(val);
@@ -7487,7 +7403,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onWhen", type = "object:org.apache.camel.model.OnWhenDefinition", description = "To use an expression to only trigger intercepting in specific situations", displayName = "On When"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition"),
@YamlProperty(name = "uri", type = "string", description = "Intercept incoming messages from the uri or uri pattern. If this option is not configured, then all incoming messages is intercepted.", displayName = "Uri")
@@ -7518,11 +7433,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onWhen": {
org.apache.camel.model.OnWhenDefinition val = asType(node, org.apache.camel.model.OnWhenDefinition.class);
target.setOnWhen(val);
@@ -7572,7 +7482,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onWhen", type = "object:org.apache.camel.model.OnWhenDefinition", description = "To use an expression to only trigger intercepting sending to an endpoint in specific situations", displayName = "On When"),
@YamlProperty(name = "skipSendToOriginalEndpoint", type = "string", description = "If set to true then the message is not sent to the original endpoint. By default (false) the message is both intercepted and then sent to the original endpoint.", displayName = "Skip Send To Original Endpoint"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition"),
@@ -7609,11 +7518,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onWhen": {
org.apache.camel.model.OnWhenDefinition val = asType(node, org.apache.camel.model.OnWhenDefinition.class);
target.setOnWhen(val);
@@ -9377,7 +9281,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "failoverLoadBalancer", type = "object:org.apache.camel.model.loadbalancer.FailoverLoadBalancerDefinition", oneOf = "loadBalancerType"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean", description = "Sets whether or not to inherit the configured error handler. The default value is true. You can use this to disable using the inherited error handler for a given DSL such as a load balancer where you want to use a custom error handler strategy.", displayName = "Inherit Error Handler"),
@YamlProperty(name = "randomLoadBalancer", type = "object:org.apache.camel.model.loadbalancer.RandomLoadBalancerDefinition", oneOf = "loadBalancerType"),
@YamlProperty(name = "roundRobinLoadBalancer", type = "object:org.apache.camel.model.loadbalancer.RoundRobinLoadBalancerDefinition", oneOf = "loadBalancerType"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition"),
@@ -9406,11 +9309,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "loadBalancerType": {
MappingNode val = asMappingNode(node);
setProperties(target, val);
@@ -9550,7 +9448,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "logLanguage", type = "string", description = "To configure the language to use. By default, the simple language is used. However, Camel also supports other languages such as groovy.", displayName = "Log Language"),
@YamlProperty(name = "logName", type = "string", description = "Sets the name of the logger. The name is default the routeId or the source:line if source location is enabled. You can also specify the name using tokens: ${class} - the logger class name (org.apache.camel.processor.LogProcessor) ${contextId} - the camel context id ${routeId} - the route id ${groupId} - the route group id ${nodeId} - the node id ${nodePrefixId} - the node prefix id ${source} - the source: [...]
@YamlProperty(name = "logger", type = "string", description = "To refer to a custom logger instance to lookup from the registry.", displayName = "Logger"),
@@ -9584,11 +9481,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "logLanguage": {
String val = asText(node);
target.setLogLanguage(val);
@@ -9653,7 +9545,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "doWhile", type = "boolean", description = "Enables the while loop that loops until the predicate evaluates to false or null.", displayName = "Do While"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to define how many times we should loop. Notice the expression is only evaluated once, and should return a number as how many times to loop. A value of zero or negative means no looping. The loop is like a for-loop fashion, if you want a while loop, then the dynamic router may be a better choice.", displayName = "Expression", oneOf = "expr [...]
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
)
@@ -9697,11 +9588,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -9762,7 +9648,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "hl7", type = "object:org.apache.camel.model.dataformat.HL7DataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "ical", type = "object:org.apache.camel.model.dataformat.IcalDataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "jacksonXml", type = "object:org.apache.camel.model.dataformat.JacksonXMLDataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "jaxb", type = "object:org.apache.camel.model.dataformat.JaxbDataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "json", type = "object:org.apache.camel.model.dataformat.JsonDataFormat", oneOf = "dataFormatType"),
@@ -10032,11 +9917,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "variableReceive": {
String val = asText(node);
target.setVariableReceive(val);
@@ -10248,7 +10128,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "executorService", type = "string", description = "Refers to a custom Thread Pool to be used for parallel processing. Notice if you set this option, then parallel processing is automatic implied, and you do not have to enable that option as well.", displayName = "Executor Service"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onPrepare", type = "string", description = "Uses the Processor when preparing the org.apache.camel.Exchange to be send. This can be used to deep-clone messages that should be send, or any custom logic needed before the exchange is send.", displayName = "On Prepare"),
@YamlProperty(name = "parallelAggregate", type = "boolean", deprecated = true, description = "If enabled then the aggregate method on AggregationStrategy can be called concurrently. Notice that this would require the implementation of AggregationStrategy to be implemented as thread-safe. By default this is false meaning that Camel synchronizes the call to the aggregate method. Though in some use-cases this can be used to archive higher performance when the Aggregation [...]
@YamlProperty(name = "parallelProcessing", type = "boolean", description = "If enabled then sending messages to the multicasts occurs concurrently. Note the caller thread will still wait until all messages has been fully processed, before it continues. Its only the sending and processing the replies from the multicasts which happens concurrently. When parallel processing is enabled, then the Camel routing engin will continue processing using last used thread from the [...]
@@ -10300,11 +10179,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExecutorService(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onPrepare": {
String val = asText(node);
target.setOnPrepare(val);
@@ -10690,7 +10564,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "executorService", type = "string", description = "To use a custom Thread Pool to be used for parallel processing. Notice if you set this option, then parallel processing is automatic implied, and you do not have to enable that option as well.", displayName = "Executor Service"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "mode", type = "enum:AfterConsumer,BeforeConsumer", defaultValue = "AfterConsumer", description = "Sets the on completion mode. The default value is AfterConsumer", displayName = "Mode"),
@YamlProperty(name = "onCompleteOnly", type = "boolean", description = "Will only synchronize when the org.apache.camel.Exchange completed successfully (no errors).", displayName = "On Complete Only"),
@YamlProperty(name = "onFailureOnly", type = "boolean", description = "Will only synchronize when the org.apache.camel.Exchange ended with failure (exception or FAULT message).", displayName = "On Failure Only"),
@@ -10725,11 +10598,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExecutorService(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "mode": {
String val = asText(node);
target.setMode(val);
@@ -10800,7 +10668,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "exception", type = "array:string", description = "A set of exceptions to react upon.", displayName = "Exception"),
@YamlProperty(name = "handled", type = "object:org.apache.camel.model.ExpressionSubElementDefinition", description = "Sets whether the exchange should be marked as handled or not.", displayName = "Handled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onExceptionOccurredRef", type = "string", description = "Sets a reference to a processor that should be processed just after an exception occurred. Can be used to perform custom logging about the occurred exception at the exact time it happened. Important: Any exception thrown from this processor will be ignored.", displayName = "On Exception Occurred Ref"),
@YamlProperty(name = "onRedeliveryRef", type = "string", description = "Sets a reference to a processor that should be processed before a redelivery attempt. Can be used to change the org.apache.camel.Exchange before its being redelivered.", displayName = "On Redelivery Ref"),
@YamlProperty(name = "onWhen", type = "object:org.apache.camel.model.OnWhenDefinition", description = "To use an expression to only trigger this in specific situations", displayName = "On When"),
@@ -10847,11 +10714,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setHandled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onExceptionOccurredRef": {
String val = asText(node);
target.setOnExceptionOccurredRef(val);
@@ -11298,7 +11160,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string"),
@YamlProperty(name = "disabled", type = "boolean"),
@YamlProperty(name = "id", type = "string"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
)
@@ -11322,11 +11183,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -11967,7 +11823,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "untilCheck", type = "string", required = true, description = "References to a java.util.function.Predicate to use for until checks. The predicate is responsible for evaluating whether the processing can resume or not. Such predicate should return true if the consumption can resume, or false otherwise. The exact point of when the predicate is called is dependent on the component, and it may be called on either one of the available events. Implemen [...]
}
)
@@ -11996,11 +11851,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "untilCheck": {
String val = asText(node);
target.setUntilCheck(val);
@@ -12035,7 +11885,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
)
@@ -12059,11 +11908,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -12097,7 +11941,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "ref", type = "string", required = true, description = "Sets a reference to use for lookup the policy in the registry.", displayName = "Ref"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
@@ -12122,11 +11965,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "ref": {
String val = asText(node);
target.setRef(val);
@@ -12166,7 +12004,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "parameters", type = "object"),
@YamlProperty(name = "timeout", type = "string", defaultValue = "20000", description = "Timeout in millis when polling from the external service. The timeout has influence about the poll enrich behavior. It basically operations in three different modes: negative value - Waits until a message is available and then returns it. Warning that this method could block indefinitely if no messages are available. 0 - Attempts to receive a message exchange immediately without wa [...]
@YamlProperty(name = "uri", type = "string", required = true, description = "Sets the uri of the endpoint to poll from.", displayName = "Uri"),
@@ -12204,11 +12041,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "timeout": {
String val = asText(node);
target.setTimeout(val);
@@ -12265,7 +12097,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression that computes the endpoint uri to use as the resource endpoint to enrich from", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidEndpoint", type = "boolean", description = "Ignore the invalidate endpoint exception when try to create a producer with that endpoint", displayName = "Ignore Invalid Endpoint"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "timeout", type = "string", defaultValue = "-1", description = "Timeout in millis when polling from the external service. The timeout has influence about the poll enrich behavior. It basically operations in three different modes: negative value - Waits until a message is available and then returns it. Warning that this method could block indefinitely if no messages are available. 0 - Attempts to receive a message exchange immediately without waiti [...]
@YamlProperty(name = "variableReceive", type = "string", description = "To use a variable to store the received message body (only body, not headers). This makes it handy to use variables for user data and to easily control what data to use for sending and receiving. Important: When using receive variable then the received body is stored only in this variable and not on the current message.", displayName = "Variable Receive")
}
@@ -12330,11 +12161,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidEndpoint(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "timeout": {
String val = asText(node);
target.setTimeout(val);
@@ -12583,7 +12409,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "ref", type = "string", required = true, description = "Reference to the Processor to lookup in the registry to use. A Processor is a class of type org.apache.camel.Processor, which can are to be called by this EIP. In this processor you have custom Java code, that can work with the message, such as to do custom business logic, special message manipulations and so on. By default, the ref, will lookup the bean in the Camel registry. The ref can use [...]
}
)
@@ -12607,11 +12432,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "ref": {
String val = asText(node);
target.setRef(val);
@@ -13202,7 +13022,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression that returns which endpoints (url) to send the message to (the recipients). If the expression return an empty value then the message is not sent to any recipients.", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidEndpoints", type = "boolean", description = "Ignore the invalidate endpoint exception when try to create a producer with that endpoint", displayName = "Ignore Invalid Endpoints"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onPrepare", type = "string", description = "Uses the Processor when preparing the org.apache.camel.Exchange to be used send. This can be used to deep-clone messages that should be send, or any custom logic needed before the exchange is send.", displayName = "On Prepare"),
@YamlProperty(name = "parallelAggregate", type = "boolean", deprecated = true, description = "If enabled then the aggregate method on AggregationStrategy can be called concurrently. Notice that this would require the implementation of AggregationStrategy to be implemented as thread-safe. By default this is false meaning that Camel synchronizes the call to the aggregate method. Though in some use-cases this can be used to archive higher performance when the Aggregation [...]
@YamlProperty(name = "parallelProcessing", type = "boolean", description = "If enabled then sending messages to the recipients occurs concurrently. Note the caller thread will still wait until all messages has been fully processed, before it continues. Its only the sending and processing the replies from the recipients which happens concurrently. When parallel processing is enabled, then the Camel routing engin will continue processing using last used thread from the [...]
@@ -13273,11 +13092,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidEndpoints(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onPrepare": {
String val = asText(node);
target.setOnPrepare(val);
@@ -13672,7 +13486,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of header to remove", displayName = "Name")
}
)
@@ -13701,11 +13514,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "name": {
String val = asText(node);
target.setName(val);
@@ -13745,7 +13553,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "excludePattern", type = "string", description = "Name or patter of headers to not remove. The pattern is matched in the following order: 1 = exact match 2 = wildcard (pattern ends with a and the name starts with the pattern) 3 = regular expression (all of above is case in-sensitive).", displayName = "Exclude Pattern"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "pattern", type = "string", required = true, description = "Name or pattern of headers to remove. The pattern is matched in the following order: 1 = exact match 2 = wildcard (pattern ends with a and the name starts with the pattern) 3 = regular expression (all of above is case in-sensitive).", displayName = "Pattern")
}
)
@@ -13779,11 +13586,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExcludePattern(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "pattern": {
String val = asText(node);
target.setPattern(val);
@@ -13823,7 +13625,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "excludePattern", type = "string", description = "Name or pattern of properties to not remove. The pattern is matched in the following order: 1 = exact match 2 = wildcard (pattern ends with a and the name starts with the pattern) 3 = regular expression (all of above is case in-sensitive).", displayName = "Exclude Pattern"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "pattern", type = "string", required = true, description = "Name or pattern of properties to remove. The pattern is matched in the following order: 1 = exact match 2 = wildcard (pattern ends with a and the name starts with the pattern) 3 = regular expression (all of above is case in-sensitive).", displayName = "Pattern")
}
)
@@ -13857,11 +13658,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExcludePattern(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "pattern": {
String val = asText(node);
target.setPattern(val);
@@ -13900,7 +13696,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of property to remove.", displayName = "Name")
}
)
@@ -13929,11 +13724,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "name": {
String val = asText(node);
target.setName(val);
@@ -13972,7 +13762,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of variable to remove.", displayName = "Name")
}
)
@@ -14001,11 +13790,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "name": {
String val = asText(node);
target.setName(val);
@@ -14043,7 +13827,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to use for re-ordering the messages, such as a header with a sequence number", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition"),
@YamlProperty(name = "streamConfig", type = "object:org.apache.camel.model.config.StreamResequencerConfig", oneOf = "resequencerConfig")
}
@@ -14073,11 +13856,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "resequencerConfig": {
MappingNode val = asMappingNode(node);
setProperties(target, val);
@@ -15223,7 +15001,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "intermittent", type = "boolean", description = "Sets whether the offsets will be intermittently present or whether they must be present in every exchange", displayName = "Intermittent"),
@YamlProperty(name = "loggingLevel", type = "enum:TRACE,DEBUG,INFO,WARN,ERROR,OFF", defaultValue = "ERROR", displayName = "Logging Level"),
@YamlProperty(name = "resumeStrategy", type = "string", required = true, description = "Sets the resume strategy to use", displayName = "Resume Strategy")
@@ -15249,11 +15026,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "intermittent": {
String val = asText(node);
target.setIntermittent(val);
@@ -15299,7 +15071,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "markRollbackOnly", type = "boolean", description = "Mark the transaction for rollback only (cannot be overruled to commit)", displayName = "Mark Rollback Only"),
@YamlProperty(name = "markRollbackOnlyLast", type = "boolean", description = "Mark only last sub transaction for rollback only. When using sub transactions (if the transaction manager support this)", displayName = "Mark Rollback Only Last"),
@YamlProperty(name = "message", type = "string", description = "Message to use in rollback exception", displayName = "Message")
@@ -15330,11 +15101,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "markRollbackOnly": {
String val = asText(node);
target.setMarkRollbackOnly(val);
@@ -15566,7 +15332,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
)
@@ -15595,11 +15360,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -15701,7 +15461,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to define the routing slip, which defines which endpoints to route the message in a pipeline style. Notice the expression is evaluated once, if you want a more dynamic style, then the dynamic router eip is a better choice.", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidEndpoints", type = "boolean", description = "Ignore the invalidate endpoint exception when try to create a producer with that endpoint", displayName = "Ignore Invalid Endpoints"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "uriDelimiter", type = "string", defaultValue = ",", description = "Sets the uri delimiter to use", displayName = "Uri Delimiter")
}
)
@@ -15745,11 +15504,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidEndpoints(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "uriDelimiter": {
String val = asText(node);
target.setUriDelimiter(val);
@@ -15827,7 +15581,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string"),
@YamlProperty(name = "disabled", type = "boolean"),
@YamlProperty(name = "id", type = "string"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "parameters", type = "object"),
@YamlProperty(name = "uri", type = "string", required = true)
}
@@ -15863,11 +15616,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "uri": {
String val = asText(node);
target.setUri(val);
@@ -15905,7 +15653,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "option", type = "array:org.apache.camel.model.PropertyExpressionDefinition", description = "Allows to save properties of the current exchange in order to re-use them in a compensation/completion callback route. Options are usually helpful e.g. to store and retrieve identifiers of objects that should be deleted in compensating actions. Option values will be transformed into input headers of the compensation/completion exchange.", displayName = "Option"),
@YamlProperty(name = "propagation", type = "enum:REQUIRED,REQUIRES_NEW,MANDATORY,SUPPORTS,NOT_SUPPORTED,NEVER", defaultValue = "REQUIRED", description = "Set the Saga propagation mode (REQUIRED, REQUIRES_NEW, MANDATORY, SUPPORTS, NOT_SUPPORTED, NEVER).", displayName = "Propagation"),
@YamlProperty(name = "sagaService", type = "string", description = "Refers to the id to lookup in the registry for the specific CamelSagaService to use.", displayName = "Saga Service"),
@@ -15948,11 +15695,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "option": {
java.util.List<org.apache.camel.model.PropertyExpressionDefinition> val = asFlatList(node, org.apache.camel.model.PropertyExpressionDefinition.class);
target.setOptions(val);
@@ -16007,7 +15749,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "messageFrequency", type = "number", description = "Sets the sample message count which only a single Exchange will pass through after this many received.", displayName = "Message Frequency"),
@YamlProperty(name = "samplePeriod", type = "string", defaultValue = "1000", description = "Sets the sample period during which only a single Exchange will pass through.", displayName = "Sample Period")
}
@@ -16037,11 +15778,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "messageFrequency": {
String val = asText(node);
target.setMessageFrequency(val);
@@ -16082,8 +15818,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to return the transformed message body (the new message body to use)", displayName = "Expression", oneOf = "expression"),
- @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean")
+ @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id")
}
)
public static class ScriptDefinitionDeserializer extends YamlDeserializerBase<ScriptDefinition> {
@@ -16111,11 +15846,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -16400,7 +16130,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expressionRef", type = "string", description = "Set a reference to a custom Expression to use.", displayName = "Expression Ref"),
@YamlProperty(name = "healthyServiceFilter", type = "object:org.apache.camel.model.cloud.HealthyServiceCallServiceFilterConfiguration", oneOf = "serviceFilterConfiguration"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "kubernetesServiceDiscovery", type = "object:org.apache.camel.model.cloud.KubernetesServiceCallServiceDiscoveryConfiguration", oneOf = "serviceDiscoveryConfiguration"),
@YamlProperty(name = "loadBalancerRef", type = "string", description = "Sets a reference to a custom ServiceLoadBalancer to use.", displayName = "Load Balancer Ref"),
@YamlProperty(name = "name", type = "string", required = true, description = "Sets the name of the service to use", displayName = "Name"),
@@ -16459,11 +16188,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpressionRef(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "defaultLoadBalancer": {
org.apache.camel.model.cloud.DefaultServiceCallServiceLoadBalancerConfiguration val = asType(node, org.apache.camel.model.cloud.DefaultServiceCallServiceLoadBalancerConfiguration.class);
target.setLoadBalancerConfiguration(val);
@@ -16860,8 +16584,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression that returns the new body to use", displayName = "Expression", oneOf = "expression"),
- @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean")
+ @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id")
}
)
public static class SetBodyDefinitionDeserializer extends YamlDeserializerBase<SetBodyDefinition> {
@@ -16889,11 +16612,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -16936,7 +16654,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "pattern", type = "enum:InOnly,InOut", description = "Sets the new exchange pattern of the Exchange to be used from this point forward", displayName = "Pattern")
}
)
@@ -16965,11 +16682,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "pattern": {
String val = asText(node);
target.setPattern(val);
@@ -17009,7 +16721,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to return the value of the header", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of message header to set a new value The simple language can be used to define a dynamic evaluated header name to be used. Otherwise a constant name will be used.", displayName = "Name")
}
)
@@ -17038,11 +16749,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "name": {
String val = asText(node);
target.setName(val);
@@ -17089,8 +16795,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "headers", type = "array:org.apache.camel.model.SetHeaderDefinition", description = "Contains the headers to be set", displayName = "Headers"),
- @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean")
+ @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id")
}
)
public static class SetHeadersDefinitionDeserializer extends YamlDeserializerBase<SetHeadersDefinition> {
@@ -17118,11 +16823,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setHeaders(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -17157,7 +16857,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to return the value of the message exchange property", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of exchange property to set a new value. The simple language can be used to define a dynamic evaluated exchange property name to be used. Otherwise a constant name will be used.", displayName = "Name")
}
)
@@ -17186,11 +16885,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "name": {
String val = asText(node);
target.setName(val);
@@ -17239,7 +16933,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to return the value of the variable", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "name", type = "string", required = true, description = "Name of variable to set a new value The simple language can be used to define a dynamic evaluated variable name to be used. Otherwise a constant name will be used.", displayName = "Name")
}
)
@@ -17268,11 +16961,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "name": {
String val = asText(node);
target.setName(val);
@@ -17319,7 +17007,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "variables", type = "array:org.apache.camel.model.SetVariableDefinition", description = "Contains the variables to be set", displayName = "Variables")
}
)
@@ -17343,11 +17030,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "variables": {
java.util.List<org.apache.camel.model.SetVariableDefinition> val = asFlatList(node, org.apache.camel.model.SetVariableDefinition.class);
target.setVariables(val);
@@ -17582,8 +17264,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Optional expression to sort by something else than the message body", displayName = "Expression", oneOf = "expression"),
- @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean")
+ @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id")
}
)
public static class SortDefinitionDeserializer extends YamlDeserializerBase<SortDefinition> {
@@ -17616,11 +17297,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -17738,7 +17414,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "executorService", type = "string", description = "To use a custom Thread Pool to be used for parallel processing. Notice if you set this option, then parallel processing is automatically implied, and you do not have to enable that option as well.", displayName = "Executor Service"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression of how to split the message body, such as as-is, using a tokenizer, or using a xpath.", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onPrepare", type = "string", description = "Uses the Processor when preparing the org.apache.camel.Exchange to be sent. This can be used to deep-clone messages that should be sent, or any custom logic needed before the exchange is sent.", displayName = "On Prepare"),
@YamlProperty(name = "parallelAggregate", type = "boolean", deprecated = true, description = "If enabled then the aggregate method on AggregationStrategy can be called concurrently. Notice that this would require the implementation of AggregationStrategy to be implemented as thread-safe. By default this is false meaning that Camel synchronizes the call to the aggregate method. Though in some use-cases this can be used to archive higher performance when the Aggregation [...]
@YamlProperty(name = "parallelProcessing", type = "boolean", description = "If enabled then processing each split messages occurs concurrently. Note the caller thread will still wait until all messages has been fully processed, before it continues. It's only processing the sub messages from the splitter which happens concurrently. When parallel processing is enabled, then the Camel routing engin will continue processing using last used thread from the parallel thread [...]
@@ -17800,11 +17475,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onPrepare": {
String val = asText(node);
target.setOnPrepare(val);
@@ -18066,7 +17736,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
)
@@ -18090,11 +17759,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -18175,8 +17839,7 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
properties = {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
- @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean")
+ @YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id")
}
)
public static class StopDefinitionDeserializer extends YamlDeserializerBase<StopDefinition> {
@@ -18199,11 +17862,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -18675,7 +18333,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "executorService", type = "string", description = "To use a custom thread pool", displayName = "Executor Service"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "keepAliveTime", type = "number", description = "Sets the keep alive time for idle threads", displayName = "Keep Alive Time"),
@YamlProperty(name = "maxPoolSize", type = "number", description = "Sets the maximum pool size", displayName = "Max Pool Size"),
@YamlProperty(name = "maxQueueSize", type = "number", description = "Sets the maximum number of tasks in the work queue. Use -1 or Integer.MAX_VALUE for an unbounded queue", displayName = "Max Queue Size"),
@@ -18720,11 +18377,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExecutorService(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "keepAliveTime": {
String val = asText(node);
target.setKeepAliveTime(val);
@@ -18858,7 +18510,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "executorService", type = "string", description = "To use a custom thread pool (ScheduledExecutorService) by the throttler.", displayName = "Executor Service"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to configure the maximum number of messages to throttle per request", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "mode", type = "enum:TotalRequests,ConcurrentRequests", defaultValue = "TotalRequests", description = "Sets the throttling mode to one of the available modes enumerated in ThrottlingMode", displayName = "Mode"),
@YamlProperty(name = "rejectExecution", type = "boolean", description = "Whether or not throttler throws the ThrottlerRejectedExecutionException when the exchange exceeds the request limit Is by default false", displayName = "Reject Execution"),
@YamlProperty(name = "timePeriodMillis", type = "string", defaultValue = "1000", description = "Sets the time period during which the maximum request count is valid for", displayName = "Time Period Millis")
@@ -18909,11 +18560,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "mode": {
String val = asText(node);
target.setMode(val);
@@ -18971,7 +18617,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "exceptionType", type = "string", description = "The class of the exception to create using the message.", displayName = "Exception Type"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "message", type = "string", description = "To create a new exception instance and use the given message as caused message (supports simple language)", displayName = "Message"),
@YamlProperty(name = "ref", type = "string", description = "Reference to the exception instance to lookup from the registry to throw", displayName = "Ref")
}
@@ -19001,11 +18646,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExceptionType(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "message": {
String val = asText(node);
target.setMessage(val);
@@ -19100,7 +18740,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "parameters", type = "object"),
@YamlProperty(name = "pattern", type = "enum:InOnly,InOut", description = "Sets the optional ExchangePattern used to invoke this endpoint", displayName = "Pattern"),
@YamlProperty(name = "uri", type = "string", required = true, description = "Sets the uri of the endpoint to send to.", displayName = "Uri"),
@@ -19139,11 +18778,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "pattern": {
String val = asText(node);
target.setPattern(val);
@@ -19201,7 +18835,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidEndpoint", type = "boolean", description = "Whether to ignore invalid endpoint URIs and skip sending the message.", displayName = "Ignore Invalid Endpoint"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "parameters", type = "object"),
@YamlProperty(name = "pattern", type = "enum:InOnly,InOut", description = "Sets the optional ExchangePattern used to invoke this endpoint", displayName = "Pattern"),
@YamlProperty(name = "uri", type = "string", required = true, description = "The uri of the endpoint to send to. The uri can be dynamic computed using the org.apache.camel.language.simple.SimpleLanguage expression.", displayName = "Uri"),
@@ -19260,11 +18893,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidEndpoint(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "pattern": {
String val = asText(node);
target.setPattern(val);
@@ -19314,7 +18942,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "langChain4jCharacterTokenizer", type = "object:org.apache.camel.model.tokenizer.LangChain4jCharacterTokenizerDefinition", oneOf = "tokenizerImplementation"),
@YamlProperty(name = "langChain4jLineTokenizer", type = "object:org.apache.camel.model.tokenizer.LangChain4jTokenizerDefinition", oneOf = "tokenizerImplementation"),
@YamlProperty(name = "langChain4jParagraphTokenizer", type = "object:org.apache.camel.model.tokenizer.LangChain4jParagraphTokenizerDefinition", oneOf = "tokenizerImplementation"),
@@ -19342,11 +18969,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "tokenizerImplementation": {
MappingNode val = asMappingNode(node);
setProperties(target, val);
@@ -19605,7 +19227,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "description", type = "string", description = "Sets the description of this node", displayName = "Description"),
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "ref", type = "string", description = "Sets a reference to use for lookup the policy in the registry.", displayName = "Ref"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
@@ -19630,11 +19251,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "ref": {
String val = asText(node);
target.setRef(val);
@@ -19676,7 +19292,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to return the transformed message body (the new message body to use)", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "fromType", type = "string", description = "From type used in data type transformation.", displayName = "From Type"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "toType", type = "string", description = "To type used as a target data type in the transformation.", displayName = "To Type")
}
)
@@ -19710,11 +19325,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setFromType(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "toType": {
String val = asText(node);
target.setToType(val);
@@ -19845,7 +19455,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "doCatch", type = "array:org.apache.camel.model.CatchDefinition", description = "Catches exceptions as part of a try, catch, finally block", displayName = "Do Catch"),
@YamlProperty(name = "doFinally", type = "object:org.apache.camel.model.FinallyDefinition", description = "Path traversed when a try, catch, finally block exits", displayName = "Do Finally"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "steps", type = "array:org.apache.camel.model.ProcessorDefinition")
}
)
@@ -19879,11 +19488,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setFinallyClause(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "id": {
String val = asText(node);
target.setId(val);
@@ -20410,7 +20014,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "hl7", type = "object:org.apache.camel.model.dataformat.HL7DataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "ical", type = "object:org.apache.camel.model.dataformat.IcalDataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "jacksonXml", type = "object:org.apache.camel.model.dataformat.JacksonXMLDataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "jaxb", type = "object:org.apache.camel.model.dataformat.JaxbDataFormat", oneOf = "dataFormatType"),
@YamlProperty(name = "json", type = "object:org.apache.camel.model.dataformat.JsonDataFormat", oneOf = "dataFormatType"),
@@ -20685,11 +20288,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setDisabled(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "variableReceive": {
String val = asText(node);
target.setVariableReceive(val);
@@ -20731,7 +20329,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "disabled", type = "boolean", description = "Whether to disable this EIP from the route during build time. Once an EIP has been disabled then it cannot be enabled later at runtime.", displayName = "Disabled"),
@YamlProperty(name = "expression", type = "object:org.apache.camel.model.language.ExpressionDefinition", description = "Expression to use for validation as a predicate. The expression should return either true or false. If returning false the message is invalid and an exception is thrown.", displayName = "Expression", oneOf = "expression"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "predicateExceptionFactory", type = "string", description = "The bean id of custom PredicateExceptionFactory to use for creating the exception when the validation fails. By default, Camel will throw PredicateValidationException. By using a custom factory you can control which exception to throw instead.", displayName = "Predicate Exception Factory")
}
)
@@ -20760,11 +20357,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setExpression(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "predicateExceptionFactory": {
String val = asText(node);
target.setPredicateExceptionFactory(val);
@@ -21208,7 +20800,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
@YamlProperty(name = "executorService", type = "string", description = "Uses a custom thread pool", displayName = "Executor Service"),
@YamlProperty(name = "id", type = "string", description = "Sets the id of this node", displayName = "Id"),
@YamlProperty(name = "ignoreInvalidEndpoint", type = "boolean", description = "Whether to ignore invalid endpoint URIs and skip sending the message.", displayName = "Ignore Invalid Endpoint"),
- @YamlProperty(name = "inheritErrorHandler", type = "boolean"),
@YamlProperty(name = "onPrepare", type = "string", description = "Uses the Processor when preparing the org.apache.camel.Exchange to be sent. This can be used to deep-clone messages that should be sent, or any custom logic needed before the exchange is sent.", displayName = "On Prepare"),
@YamlProperty(name = "parameters", type = "object"),
@YamlProperty(name = "pattern", type = "enum:InOnly,InOut", description = "Sets the optional ExchangePattern used to invoke this endpoint", displayName = "Pattern"),
@@ -21278,11 +20869,6 @@ public final class ModelDeserializers extends YamlDeserializerSupport {
target.setIgnoreInvalidEndpoint(val);
break;
}
- case "inheritErrorHandler": {
- String val = asText(node);
- target.setInheritErrorHandler(java.lang.Boolean.valueOf(val));
- break;
- }
case "onPrepare": {
String val = asText(node);
target.setOnPrepare(val);
diff --git a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/schema/camelYamlDsl.json b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/schema/camelYamlDsl.json
index e18c176e128..514a3be0ef1 100644
--- a/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/schema/camelYamlDsl.json
+++ b/dsl/camel-yaml-dsl/camel-yaml-dsl/src/generated/resources/schema/camelYamlDsl.json
@@ -2591,11 +2591,6 @@
"title" : "Id",
"description" : "Sets the id of this node"
},
- "inheritErrorHandler" : {
- "type" : "boolean",
- "title" : "Inherit Error Handler",
- "description" : "Sets whether or not to inherit the configured error handler. The default value is true. You can use this to disable using the inherited error handler for a given DSL such as a load balancer where you want to use a custom error handler strategy."
- },
"steps" : {
"type" : "array",
"items" : {
diff --git a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/SchemaGeneratorMojo.java b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/SchemaGeneratorMojo.java
index 7003291fde6..7b5f234a43d 100644
--- a/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/SchemaGeneratorMojo.java
+++ b/tooling/maven/camel-package-maven-plugin/src/main/java/org/apache/camel/maven/packaging/SchemaGeneratorMojo.java
@@ -509,13 +509,6 @@ public class SchemaGeneratorMojo extends AbstractGeneratorMojo {
name = fieldName;
}
- // we want to skip inheritErrorHandler which is only applicable for
- // the load-balancer
- boolean loadBalancer = "LoadBalanceDefinition".equals(originalClassType.getSimpleName());
- if (!loadBalancer && "inheritErrorHandler".equals(name)) {
- return true;
- }
-
Metadata metadata = fieldElement.getAnnotation(Metadata.class);
name = prefix + name;