This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit d10aec3fb2fe26193ab1e1f6ec3e5c9960c35697
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed Apr 8 14:41:02 2020 +0200
CAMEL-14860: Generate configurer for circuit breaker configuration classes
so we can avoid reflection in reifiers
---
...ToleranceConfigurationDefinitionConfigurer.java | 110 ++++++++++++
.../HystrixConfigurationDefinitionConfigurer.java | 200 +++++++++++++++++++++
...ilience4jConfigurationDefinitionConfigurer.java | 140 +++++++++++++++
.../FaultToleranceConfigurationDefinition | 2 +
.../configurer/HystrixConfigurationDefinition | 2 +
.../configurer/Resilience4jConfigurationDefinition | 2 +
.../FaultToleranceConfigurationDefinition.java | 2 +
.../model/HystrixConfigurationDefinition.java | 2 +
.../model/Resilience4jConfigurationDefinition.java | 2 +
9 files changed, 462 insertions(+)
diff --git
a/core/camel-core-engine/src/generated/java/org/apache/camel/model/FaultToleranceConfigurationDefinitionConfigurer.java
b/core/camel-core-engine/src/generated/java/org/apache/camel/model/FaultToleranceConfigurationDefinitionConfigurer.java
new file mode 100644
index 0000000..9d2c49d
--- /dev/null
+++
b/core/camel-core-engine/src/generated/java/org/apache/camel/model/FaultToleranceConfigurationDefinitionConfigurer.java
@@ -0,0 +1,110 @@
+/* Generated by camel build tools - do NOT edit this file! */
+package org.apache.camel.model;
+
+import java.util.Map;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.spi.GeneratedPropertyConfigurer;
+import org.apache.camel.spi.PropertyConfigurerGetter;
+import org.apache.camel.util.CaseInsensitiveMap;
+import org.apache.camel.model.FaultToleranceConfigurationDefinition;
+
+/**
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@SuppressWarnings("unchecked")
+public class FaultToleranceConfigurationDefinitionConfigurer extends
org.apache.camel.support.component.PropertyConfigurerSupport implements
GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+
+ @Override
+ public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
+ org.apache.camel.model.FaultToleranceConfigurationDefinition target =
(org.apache.camel.model.FaultToleranceConfigurationDefinition) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "bulkheadenabled":
+ case "BulkheadEnabled":
target.setBulkheadEnabled(property(camelContext, java.lang.String.class,
value)); return true;
+ case "bulkheadexecutorserviceref":
+ case "BulkheadExecutorServiceRef":
target.setBulkheadExecutorServiceRef(property(camelContext,
java.lang.String.class, value)); return true;
+ case "bulkheadmaxconcurrentcalls":
+ case "BulkheadMaxConcurrentCalls":
target.setBulkheadMaxConcurrentCalls(property(camelContext,
java.lang.String.class, value)); return true;
+ case "bulkheadwaitingtaskqueue":
+ case "BulkheadWaitingTaskQueue":
target.setBulkheadWaitingTaskQueue(property(camelContext,
java.lang.String.class, value)); return true;
+ case "circuitbreakerref":
+ case "CircuitBreakerRef":
target.setCircuitBreakerRef(property(camelContext, java.lang.String.class,
value)); return true;
+ case "delay":
+ case "Delay": target.setDelay(property(camelContext,
java.lang.String.class, value)); return true;
+ case "failureratio":
+ case "FailureRatio": target.setFailureRatio(property(camelContext,
java.lang.String.class, value)); return true;
+ case "id":
+ case "Id": target.setId(property(camelContext, java.lang.String.class,
value)); return true;
+ case "requestvolumethreshold":
+ case "RequestVolumeThreshold":
target.setRequestVolumeThreshold(property(camelContext, java.lang.String.class,
value)); return true;
+ case "successthreshold":
+ case "SuccessThreshold":
target.setSuccessThreshold(property(camelContext, java.lang.String.class,
value)); return true;
+ case "timeoutduration":
+ case "TimeoutDuration":
target.setTimeoutDuration(property(camelContext, java.lang.String.class,
value)); return true;
+ case "timeoutenabled":
+ case "TimeoutEnabled": target.setTimeoutEnabled(property(camelContext,
java.lang.String.class, value)); return true;
+ case "timeoutpoolsize":
+ case "TimeoutPoolSize":
target.setTimeoutPoolSize(property(camelContext, java.lang.String.class,
value)); return true;
+ case "timeoutscheduledexecutorserviceref":
+ case "TimeoutScheduledExecutorServiceRef":
target.setTimeoutScheduledExecutorServiceRef(property(camelContext,
java.lang.String.class, value)); return true;
+ default: return false;
+ }
+ }
+
+ @Override
+ public Map<String, Object> getAllOptions(Object target) {
+ Map<String, Object> answer = new CaseInsensitiveMap();
+ answer.put("BulkheadEnabled", java.lang.String.class);
+ answer.put("BulkheadExecutorServiceRef", java.lang.String.class);
+ answer.put("BulkheadMaxConcurrentCalls", java.lang.String.class);
+ answer.put("BulkheadWaitingTaskQueue", java.lang.String.class);
+ answer.put("CircuitBreakerRef", java.lang.String.class);
+ answer.put("Delay", java.lang.String.class);
+ answer.put("FailureRatio", java.lang.String.class);
+ answer.put("Id", java.lang.String.class);
+ answer.put("RequestVolumeThreshold", java.lang.String.class);
+ answer.put("SuccessThreshold", java.lang.String.class);
+ answer.put("TimeoutDuration", java.lang.String.class);
+ answer.put("TimeoutEnabled", java.lang.String.class);
+ answer.put("TimeoutPoolSize", java.lang.String.class);
+ answer.put("TimeoutScheduledExecutorServiceRef",
java.lang.String.class);
+ return answer;
+ }
+
+ @Override
+ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
+ org.apache.camel.model.FaultToleranceConfigurationDefinition target =
(org.apache.camel.model.FaultToleranceConfigurationDefinition) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "bulkheadenabled":
+ case "BulkheadEnabled": return target.getBulkheadEnabled();
+ case "bulkheadexecutorserviceref":
+ case "BulkheadExecutorServiceRef": return
target.getBulkheadExecutorServiceRef();
+ case "bulkheadmaxconcurrentcalls":
+ case "BulkheadMaxConcurrentCalls": return
target.getBulkheadMaxConcurrentCalls();
+ case "bulkheadwaitingtaskqueue":
+ case "BulkheadWaitingTaskQueue": return
target.getBulkheadWaitingTaskQueue();
+ case "circuitbreakerref":
+ case "CircuitBreakerRef": return target.getCircuitBreakerRef();
+ case "delay":
+ case "Delay": return target.getDelay();
+ case "failureratio":
+ case "FailureRatio": return target.getFailureRatio();
+ case "id":
+ case "Id": return target.getId();
+ case "requestvolumethreshold":
+ case "RequestVolumeThreshold": return
target.getRequestVolumeThreshold();
+ case "successthreshold":
+ case "SuccessThreshold": return target.getSuccessThreshold();
+ case "timeoutduration":
+ case "TimeoutDuration": return target.getTimeoutDuration();
+ case "timeoutenabled":
+ case "TimeoutEnabled": return target.getTimeoutEnabled();
+ case "timeoutpoolsize":
+ case "TimeoutPoolSize": return target.getTimeoutPoolSize();
+ case "timeoutscheduledexecutorserviceref":
+ case "TimeoutScheduledExecutorServiceRef": return
target.getTimeoutScheduledExecutorServiceRef();
+ default: return null;
+ }
+ }
+}
+
diff --git
a/core/camel-core-engine/src/generated/java/org/apache/camel/model/HystrixConfigurationDefinitionConfigurer.java
b/core/camel-core-engine/src/generated/java/org/apache/camel/model/HystrixConfigurationDefinitionConfigurer.java
new file mode 100644
index 0000000..c2bc575
--- /dev/null
+++
b/core/camel-core-engine/src/generated/java/org/apache/camel/model/HystrixConfigurationDefinitionConfigurer.java
@@ -0,0 +1,200 @@
+/* Generated by camel build tools - do NOT edit this file! */
+package org.apache.camel.model;
+
+import java.util.Map;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.spi.GeneratedPropertyConfigurer;
+import org.apache.camel.spi.PropertyConfigurerGetter;
+import org.apache.camel.util.CaseInsensitiveMap;
+import org.apache.camel.model.HystrixConfigurationDefinition;
+
+/**
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@SuppressWarnings("unchecked")
+public class HystrixConfigurationDefinitionConfigurer extends
org.apache.camel.support.component.PropertyConfigurerSupport implements
GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+
+ @Override
+ public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
+ org.apache.camel.model.HystrixConfigurationDefinition target =
(org.apache.camel.model.HystrixConfigurationDefinition) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowmaximumsizetodivergefromcoresize":
+ case "AllowMaximumSizeToDivergeFromCoreSize":
target.setAllowMaximumSizeToDivergeFromCoreSize(property(camelContext,
java.lang.String.class, value)); return true;
+ case "circuitbreakerenabled":
+ case "CircuitBreakerEnabled":
target.setCircuitBreakerEnabled(property(camelContext, java.lang.String.class,
value)); return true;
+ case "circuitbreakererrorthresholdpercentage":
+ case "CircuitBreakerErrorThresholdPercentage":
target.setCircuitBreakerErrorThresholdPercentage(property(camelContext,
java.lang.String.class, value)); return true;
+ case "circuitbreakerforceclosed":
+ case "CircuitBreakerForceClosed":
target.setCircuitBreakerForceClosed(property(camelContext,
java.lang.String.class, value)); return true;
+ case "circuitbreakerforceopen":
+ case "CircuitBreakerForceOpen":
target.setCircuitBreakerForceOpen(property(camelContext,
java.lang.String.class, value)); return true;
+ case "circuitbreakerrequestvolumethreshold":
+ case "CircuitBreakerRequestVolumeThreshold":
target.setCircuitBreakerRequestVolumeThreshold(property(camelContext,
java.lang.String.class, value)); return true;
+ case "circuitbreakersleepwindowinmilliseconds":
+ case "CircuitBreakerSleepWindowInMilliseconds":
target.setCircuitBreakerSleepWindowInMilliseconds(property(camelContext,
java.lang.String.class, value)); return true;
+ case "corepoolsize":
+ case "CorePoolSize": target.setCorePoolSize(property(camelContext,
java.lang.String.class, value)); return true;
+ case "executionisolationsemaphoremaxconcurrentrequests":
+ case "ExecutionIsolationSemaphoreMaxConcurrentRequests":
target.setExecutionIsolationSemaphoreMaxConcurrentRequests(property(camelContext,
java.lang.String.class, value)); return true;
+ case "executionisolationstrategy":
+ case "ExecutionIsolationStrategy":
target.setExecutionIsolationStrategy(property(camelContext,
java.lang.String.class, value)); return true;
+ case "executionisolationthreadinterruptontimeout":
+ case "ExecutionIsolationThreadInterruptOnTimeout":
target.setExecutionIsolationThreadInterruptOnTimeout(property(camelContext,
java.lang.String.class, value)); return true;
+ case "executiontimeoutenabled":
+ case "ExecutionTimeoutEnabled":
target.setExecutionTimeoutEnabled(property(camelContext,
java.lang.String.class, value)); return true;
+ case "executiontimeoutinmilliseconds":
+ case "ExecutionTimeoutInMilliseconds":
target.setExecutionTimeoutInMilliseconds(property(camelContext,
java.lang.String.class, value)); return true;
+ case "fallbackenabled":
+ case "FallbackEnabled":
target.setFallbackEnabled(property(camelContext, java.lang.String.class,
value)); return true;
+ case "fallbackisolationsemaphoremaxconcurrentrequests":
+ case "FallbackIsolationSemaphoreMaxConcurrentRequests":
target.setFallbackIsolationSemaphoreMaxConcurrentRequests(property(camelContext,
java.lang.String.class, value)); return true;
+ case "groupkey":
+ case "GroupKey": target.setGroupKey(property(camelContext,
java.lang.String.class, value)); return true;
+ case "id":
+ case "Id": target.setId(property(camelContext, java.lang.String.class,
value)); return true;
+ case "keepalivetime":
+ case "KeepAliveTime": target.setKeepAliveTime(property(camelContext,
java.lang.String.class, value)); return true;
+ case "maxqueuesize":
+ case "MaxQueueSize": target.setMaxQueueSize(property(camelContext,
java.lang.String.class, value)); return true;
+ case "maximumsize":
+ case "MaximumSize": target.setMaximumSize(property(camelContext,
java.lang.String.class, value)); return true;
+ case "metricshealthsnapshotintervalinmilliseconds":
+ case "MetricsHealthSnapshotIntervalInMilliseconds":
target.setMetricsHealthSnapshotIntervalInMilliseconds(property(camelContext,
java.lang.String.class, value)); return true;
+ case "metricsrollingpercentilebucketsize":
+ case "MetricsRollingPercentileBucketSize":
target.setMetricsRollingPercentileBucketSize(property(camelContext,
java.lang.String.class, value)); return true;
+ case "metricsrollingpercentileenabled":
+ case "MetricsRollingPercentileEnabled":
target.setMetricsRollingPercentileEnabled(property(camelContext,
java.lang.String.class, value)); return true;
+ case "metricsrollingpercentilewindowbuckets":
+ case "MetricsRollingPercentileWindowBuckets":
target.setMetricsRollingPercentileWindowBuckets(property(camelContext,
java.lang.String.class, value)); return true;
+ case "metricsrollingpercentilewindowinmilliseconds":
+ case "MetricsRollingPercentileWindowInMilliseconds":
target.setMetricsRollingPercentileWindowInMilliseconds(property(camelContext,
java.lang.String.class, value)); return true;
+ case "metricsrollingstatisticalwindowbuckets":
+ case "MetricsRollingStatisticalWindowBuckets":
target.setMetricsRollingStatisticalWindowBuckets(property(camelContext,
java.lang.String.class, value)); return true;
+ case "metricsrollingstatisticalwindowinmilliseconds":
+ case "MetricsRollingStatisticalWindowInMilliseconds":
target.setMetricsRollingStatisticalWindowInMilliseconds(property(camelContext,
java.lang.String.class, value)); return true;
+ case "queuesizerejectionthreshold":
+ case "QueueSizeRejectionThreshold":
target.setQueueSizeRejectionThreshold(property(camelContext,
java.lang.String.class, value)); return true;
+ case "requestlogenabled":
+ case "RequestLogEnabled":
target.setRequestLogEnabled(property(camelContext, java.lang.String.class,
value)); return true;
+ case "threadpoolkey":
+ case "ThreadPoolKey": target.setThreadPoolKey(property(camelContext,
java.lang.String.class, value)); return true;
+ case "threadpoolrollingnumberstatisticalwindowbuckets":
+ case "ThreadPoolRollingNumberStatisticalWindowBuckets":
target.setThreadPoolRollingNumberStatisticalWindowBuckets(property(camelContext,
java.lang.String.class, value)); return true;
+ case "threadpoolrollingnumberstatisticalwindowinmilliseconds":
+ case "ThreadPoolRollingNumberStatisticalWindowInMilliseconds":
target.setThreadPoolRollingNumberStatisticalWindowInMilliseconds(property(camelContext,
java.lang.String.class, value)); return true;
+ default: return false;
+ }
+ }
+
+ @Override
+ public Map<String, Object> getAllOptions(Object target) {
+ Map<String, Object> answer = new CaseInsensitiveMap();
+ answer.put("AllowMaximumSizeToDivergeFromCoreSize",
java.lang.String.class);
+ answer.put("CircuitBreakerEnabled", java.lang.String.class);
+ answer.put("CircuitBreakerErrorThresholdPercentage",
java.lang.String.class);
+ answer.put("CircuitBreakerForceClosed", java.lang.String.class);
+ answer.put("CircuitBreakerForceOpen", java.lang.String.class);
+ answer.put("CircuitBreakerRequestVolumeThreshold",
java.lang.String.class);
+ answer.put("CircuitBreakerSleepWindowInMilliseconds",
java.lang.String.class);
+ answer.put("CorePoolSize", java.lang.String.class);
+ answer.put("ExecutionIsolationSemaphoreMaxConcurrentRequests",
java.lang.String.class);
+ answer.put("ExecutionIsolationStrategy", java.lang.String.class);
+ answer.put("ExecutionIsolationThreadInterruptOnTimeout",
java.lang.String.class);
+ answer.put("ExecutionTimeoutEnabled", java.lang.String.class);
+ answer.put("ExecutionTimeoutInMilliseconds", java.lang.String.class);
+ answer.put("FallbackEnabled", java.lang.String.class);
+ answer.put("FallbackIsolationSemaphoreMaxConcurrentRequests",
java.lang.String.class);
+ answer.put("GroupKey", java.lang.String.class);
+ answer.put("Id", java.lang.String.class);
+ answer.put("KeepAliveTime", java.lang.String.class);
+ answer.put("MaxQueueSize", java.lang.String.class);
+ answer.put("MaximumSize", java.lang.String.class);
+ answer.put("MetricsHealthSnapshotIntervalInMilliseconds",
java.lang.String.class);
+ answer.put("MetricsRollingPercentileBucketSize",
java.lang.String.class);
+ answer.put("MetricsRollingPercentileEnabled", java.lang.String.class);
+ answer.put("MetricsRollingPercentileWindowBuckets",
java.lang.String.class);
+ answer.put("MetricsRollingPercentileWindowInMilliseconds",
java.lang.String.class);
+ answer.put("MetricsRollingStatisticalWindowBuckets",
java.lang.String.class);
+ answer.put("MetricsRollingStatisticalWindowInMilliseconds",
java.lang.String.class);
+ answer.put("QueueSizeRejectionThreshold", java.lang.String.class);
+ answer.put("RequestLogEnabled", java.lang.String.class);
+ answer.put("ThreadPoolKey", java.lang.String.class);
+ answer.put("ThreadPoolRollingNumberStatisticalWindowBuckets",
java.lang.String.class);
+ answer.put("ThreadPoolRollingNumberStatisticalWindowInMilliseconds",
java.lang.String.class);
+ return answer;
+ }
+
+ @Override
+ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
+ org.apache.camel.model.HystrixConfigurationDefinition target =
(org.apache.camel.model.HystrixConfigurationDefinition) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "allowmaximumsizetodivergefromcoresize":
+ case "AllowMaximumSizeToDivergeFromCoreSize": return
target.getAllowMaximumSizeToDivergeFromCoreSize();
+ case "circuitbreakerenabled":
+ case "CircuitBreakerEnabled": return target.getCircuitBreakerEnabled();
+ case "circuitbreakererrorthresholdpercentage":
+ case "CircuitBreakerErrorThresholdPercentage": return
target.getCircuitBreakerErrorThresholdPercentage();
+ case "circuitbreakerforceclosed":
+ case "CircuitBreakerForceClosed": return
target.getCircuitBreakerForceClosed();
+ case "circuitbreakerforceopen":
+ case "CircuitBreakerForceOpen": return
target.getCircuitBreakerForceOpen();
+ case "circuitbreakerrequestvolumethreshold":
+ case "CircuitBreakerRequestVolumeThreshold": return
target.getCircuitBreakerRequestVolumeThreshold();
+ case "circuitbreakersleepwindowinmilliseconds":
+ case "CircuitBreakerSleepWindowInMilliseconds": return
target.getCircuitBreakerSleepWindowInMilliseconds();
+ case "corepoolsize":
+ case "CorePoolSize": return target.getCorePoolSize();
+ case "executionisolationsemaphoremaxconcurrentrequests":
+ case "ExecutionIsolationSemaphoreMaxConcurrentRequests": return
target.getExecutionIsolationSemaphoreMaxConcurrentRequests();
+ case "executionisolationstrategy":
+ case "ExecutionIsolationStrategy": return
target.getExecutionIsolationStrategy();
+ case "executionisolationthreadinterruptontimeout":
+ case "ExecutionIsolationThreadInterruptOnTimeout": return
target.getExecutionIsolationThreadInterruptOnTimeout();
+ case "executiontimeoutenabled":
+ case "ExecutionTimeoutEnabled": return
target.getExecutionTimeoutEnabled();
+ case "executiontimeoutinmilliseconds":
+ case "ExecutionTimeoutInMilliseconds": return
target.getExecutionTimeoutInMilliseconds();
+ case "fallbackenabled":
+ case "FallbackEnabled": return target.getFallbackEnabled();
+ case "fallbackisolationsemaphoremaxconcurrentrequests":
+ case "FallbackIsolationSemaphoreMaxConcurrentRequests": return
target.getFallbackIsolationSemaphoreMaxConcurrentRequests();
+ case "groupkey":
+ case "GroupKey": return target.getGroupKey();
+ case "id":
+ case "Id": return target.getId();
+ case "keepalivetime":
+ case "KeepAliveTime": return target.getKeepAliveTime();
+ case "maxqueuesize":
+ case "MaxQueueSize": return target.getMaxQueueSize();
+ case "maximumsize":
+ case "MaximumSize": return target.getMaximumSize();
+ case "metricshealthsnapshotintervalinmilliseconds":
+ case "MetricsHealthSnapshotIntervalInMilliseconds": return
target.getMetricsHealthSnapshotIntervalInMilliseconds();
+ case "metricsrollingpercentilebucketsize":
+ case "MetricsRollingPercentileBucketSize": return
target.getMetricsRollingPercentileBucketSize();
+ case "metricsrollingpercentileenabled":
+ case "MetricsRollingPercentileEnabled": return
target.getMetricsRollingPercentileEnabled();
+ case "metricsrollingpercentilewindowbuckets":
+ case "MetricsRollingPercentileWindowBuckets": return
target.getMetricsRollingPercentileWindowBuckets();
+ case "metricsrollingpercentilewindowinmilliseconds":
+ case "MetricsRollingPercentileWindowInMilliseconds": return
target.getMetricsRollingPercentileWindowInMilliseconds();
+ case "metricsrollingstatisticalwindowbuckets":
+ case "MetricsRollingStatisticalWindowBuckets": return
target.getMetricsRollingStatisticalWindowBuckets();
+ case "metricsrollingstatisticalwindowinmilliseconds":
+ case "MetricsRollingStatisticalWindowInMilliseconds": return
target.getMetricsRollingStatisticalWindowInMilliseconds();
+ case "queuesizerejectionthreshold":
+ case "QueueSizeRejectionThreshold": return
target.getQueueSizeRejectionThreshold();
+ case "requestlogenabled":
+ case "RequestLogEnabled": return target.getRequestLogEnabled();
+ case "threadpoolkey":
+ case "ThreadPoolKey": return target.getThreadPoolKey();
+ case "threadpoolrollingnumberstatisticalwindowbuckets":
+ case "ThreadPoolRollingNumberStatisticalWindowBuckets": return
target.getThreadPoolRollingNumberStatisticalWindowBuckets();
+ case "threadpoolrollingnumberstatisticalwindowinmilliseconds":
+ case "ThreadPoolRollingNumberStatisticalWindowInMilliseconds": return
target.getThreadPoolRollingNumberStatisticalWindowInMilliseconds();
+ default: return null;
+ }
+ }
+}
+
diff --git
a/core/camel-core-engine/src/generated/java/org/apache/camel/model/Resilience4jConfigurationDefinitionConfigurer.java
b/core/camel-core-engine/src/generated/java/org/apache/camel/model/Resilience4jConfigurationDefinitionConfigurer.java
new file mode 100644
index 0000000..f397b9c
--- /dev/null
+++
b/core/camel-core-engine/src/generated/java/org/apache/camel/model/Resilience4jConfigurationDefinitionConfigurer.java
@@ -0,0 +1,140 @@
+/* Generated by camel build tools - do NOT edit this file! */
+package org.apache.camel.model;
+
+import java.util.Map;
+
+import org.apache.camel.CamelContext;
+import org.apache.camel.spi.GeneratedPropertyConfigurer;
+import org.apache.camel.spi.PropertyConfigurerGetter;
+import org.apache.camel.util.CaseInsensitiveMap;
+import org.apache.camel.model.Resilience4jConfigurationDefinition;
+
+/**
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@SuppressWarnings("unchecked")
+public class Resilience4jConfigurationDefinitionConfigurer extends
org.apache.camel.support.component.PropertyConfigurerSupport implements
GeneratedPropertyConfigurer, PropertyConfigurerGetter {
+
+ @Override
+ public boolean configure(CamelContext camelContext, Object obj, String
name, Object value, boolean ignoreCase) {
+ org.apache.camel.model.Resilience4jConfigurationDefinition target =
(org.apache.camel.model.Resilience4jConfigurationDefinition) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "automatictransitionfromopentohalfopenenabled":
+ case "AutomaticTransitionFromOpenToHalfOpenEnabled":
target.setAutomaticTransitionFromOpenToHalfOpenEnabled(property(camelContext,
java.lang.String.class, value)); return true;
+ case "bulkheadenabled":
+ case "BulkheadEnabled":
target.setBulkheadEnabled(property(camelContext, java.lang.String.class,
value)); return true;
+ case "bulkheadmaxconcurrentcalls":
+ case "BulkheadMaxConcurrentCalls":
target.setBulkheadMaxConcurrentCalls(property(camelContext,
java.lang.String.class, value)); return true;
+ case "bulkheadmaxwaitduration":
+ case "BulkheadMaxWaitDuration":
target.setBulkheadMaxWaitDuration(property(camelContext,
java.lang.String.class, value)); return true;
+ case "circuitbreakerref":
+ case "CircuitBreakerRef":
target.setCircuitBreakerRef(property(camelContext, java.lang.String.class,
value)); return true;
+ case "configref":
+ case "ConfigRef": target.setConfigRef(property(camelContext,
java.lang.String.class, value)); return true;
+ case "failureratethreshold":
+ case "FailureRateThreshold":
target.setFailureRateThreshold(property(camelContext, java.lang.String.class,
value)); return true;
+ case "id":
+ case "Id": target.setId(property(camelContext, java.lang.String.class,
value)); return true;
+ case "minimumnumberofcalls":
+ case "MinimumNumberOfCalls":
target.setMinimumNumberOfCalls(property(camelContext, java.lang.String.class,
value)); return true;
+ case "permittednumberofcallsinhalfopenstate":
+ case "PermittedNumberOfCallsInHalfOpenState":
target.setPermittedNumberOfCallsInHalfOpenState(property(camelContext,
java.lang.String.class, value)); return true;
+ case "slidingwindowsize":
+ case "SlidingWindowSize":
target.setSlidingWindowSize(property(camelContext, java.lang.String.class,
value)); return true;
+ case "slidingwindowtype":
+ case "SlidingWindowType":
target.setSlidingWindowType(property(camelContext, java.lang.String.class,
value)); return true;
+ case "slowcalldurationthreshold":
+ case "SlowCallDurationThreshold":
target.setSlowCallDurationThreshold(property(camelContext,
java.lang.String.class, value)); return true;
+ case "slowcallratethreshold":
+ case "SlowCallRateThreshold":
target.setSlowCallRateThreshold(property(camelContext, java.lang.String.class,
value)); return true;
+ case "timeoutcancelrunningfuture":
+ case "TimeoutCancelRunningFuture":
target.setTimeoutCancelRunningFuture(property(camelContext,
java.lang.String.class, value)); return true;
+ case "timeoutduration":
+ case "TimeoutDuration":
target.setTimeoutDuration(property(camelContext, java.lang.String.class,
value)); return true;
+ case "timeoutenabled":
+ case "TimeoutEnabled": target.setTimeoutEnabled(property(camelContext,
java.lang.String.class, value)); return true;
+ case "timeoutexecutorserviceref":
+ case "TimeoutExecutorServiceRef":
target.setTimeoutExecutorServiceRef(property(camelContext,
java.lang.String.class, value)); return true;
+ case "waitdurationinopenstate":
+ case "WaitDurationInOpenState":
target.setWaitDurationInOpenState(property(camelContext,
java.lang.String.class, value)); return true;
+ case "writablestacktraceenabled":
+ case "WritableStackTraceEnabled":
target.setWritableStackTraceEnabled(property(camelContext,
java.lang.String.class, value)); return true;
+ default: return false;
+ }
+ }
+
+ @Override
+ public Map<String, Object> getAllOptions(Object target) {
+ Map<String, Object> answer = new CaseInsensitiveMap();
+ answer.put("AutomaticTransitionFromOpenToHalfOpenEnabled",
java.lang.String.class);
+ answer.put("BulkheadEnabled", java.lang.String.class);
+ answer.put("BulkheadMaxConcurrentCalls", java.lang.String.class);
+ answer.put("BulkheadMaxWaitDuration", java.lang.String.class);
+ answer.put("CircuitBreakerRef", java.lang.String.class);
+ answer.put("ConfigRef", java.lang.String.class);
+ answer.put("FailureRateThreshold", java.lang.String.class);
+ answer.put("Id", java.lang.String.class);
+ answer.put("MinimumNumberOfCalls", java.lang.String.class);
+ answer.put("PermittedNumberOfCallsInHalfOpenState",
java.lang.String.class);
+ answer.put("SlidingWindowSize", java.lang.String.class);
+ answer.put("SlidingWindowType", java.lang.String.class);
+ answer.put("SlowCallDurationThreshold", java.lang.String.class);
+ answer.put("SlowCallRateThreshold", java.lang.String.class);
+ answer.put("TimeoutCancelRunningFuture", java.lang.String.class);
+ answer.put("TimeoutDuration", java.lang.String.class);
+ answer.put("TimeoutEnabled", java.lang.String.class);
+ answer.put("TimeoutExecutorServiceRef", java.lang.String.class);
+ answer.put("WaitDurationInOpenState", java.lang.String.class);
+ answer.put("WritableStackTraceEnabled", java.lang.String.class);
+ return answer;
+ }
+
+ @Override
+ public Object getOptionValue(Object obj, String name, boolean ignoreCase) {
+ org.apache.camel.model.Resilience4jConfigurationDefinition target =
(org.apache.camel.model.Resilience4jConfigurationDefinition) obj;
+ switch (ignoreCase ? name.toLowerCase() : name) {
+ case "automatictransitionfromopentohalfopenenabled":
+ case "AutomaticTransitionFromOpenToHalfOpenEnabled": return
target.getAutomaticTransitionFromOpenToHalfOpenEnabled();
+ case "bulkheadenabled":
+ case "BulkheadEnabled": return target.getBulkheadEnabled();
+ case "bulkheadmaxconcurrentcalls":
+ case "BulkheadMaxConcurrentCalls": return
target.getBulkheadMaxConcurrentCalls();
+ case "bulkheadmaxwaitduration":
+ case "BulkheadMaxWaitDuration": return
target.getBulkheadMaxWaitDuration();
+ case "circuitbreakerref":
+ case "CircuitBreakerRef": return target.getCircuitBreakerRef();
+ case "configref":
+ case "ConfigRef": return target.getConfigRef();
+ case "failureratethreshold":
+ case "FailureRateThreshold": return target.getFailureRateThreshold();
+ case "id":
+ case "Id": return target.getId();
+ case "minimumnumberofcalls":
+ case "MinimumNumberOfCalls": return target.getMinimumNumberOfCalls();
+ case "permittednumberofcallsinhalfopenstate":
+ case "PermittedNumberOfCallsInHalfOpenState": return
target.getPermittedNumberOfCallsInHalfOpenState();
+ case "slidingwindowsize":
+ case "SlidingWindowSize": return target.getSlidingWindowSize();
+ case "slidingwindowtype":
+ case "SlidingWindowType": return target.getSlidingWindowType();
+ case "slowcalldurationthreshold":
+ case "SlowCallDurationThreshold": return
target.getSlowCallDurationThreshold();
+ case "slowcallratethreshold":
+ case "SlowCallRateThreshold": return target.getSlowCallRateThreshold();
+ case "timeoutcancelrunningfuture":
+ case "TimeoutCancelRunningFuture": return
target.getTimeoutCancelRunningFuture();
+ case "timeoutduration":
+ case "TimeoutDuration": return target.getTimeoutDuration();
+ case "timeoutenabled":
+ case "TimeoutEnabled": return target.getTimeoutEnabled();
+ case "timeoutexecutorserviceref":
+ case "TimeoutExecutorServiceRef": return
target.getTimeoutExecutorServiceRef();
+ case "waitdurationinopenstate":
+ case "WaitDurationInOpenState": return
target.getWaitDurationInOpenState();
+ case "writablestacktraceenabled":
+ case "WritableStackTraceEnabled": return
target.getWritableStackTraceEnabled();
+ default: return null;
+ }
+ }
+}
+
diff --git
a/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/FaultToleranceConfigurationDefinition
b/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/FaultToleranceConfigurationDefinition
new file mode 100644
index 0000000..c84d003
--- /dev/null
+++
b/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/FaultToleranceConfigurationDefinition
@@ -0,0 +1,2 @@
+# Generated by camel build tools - do NOT edit this file!
+class=org.apache.camel.model.FaultToleranceConfigurationDefinitionConfigurer
diff --git
a/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/HystrixConfigurationDefinition
b/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/HystrixConfigurationDefinition
new file mode 100644
index 0000000..495b0f6
--- /dev/null
+++
b/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/HystrixConfigurationDefinition
@@ -0,0 +1,2 @@
+# Generated by camel build tools - do NOT edit this file!
+class=org.apache.camel.model.HystrixConfigurationDefinitionConfigurer
diff --git
a/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/Resilience4jConfigurationDefinition
b/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/Resilience4jConfigurationDefinition
new file mode 100644
index 0000000..b2c684d
--- /dev/null
+++
b/core/camel-core-engine/src/generated/resources/META-INF/services/org/apache/camel/configurer/Resilience4jConfigurationDefinition
@@ -0,0 +1,2 @@
+# Generated by camel build tools - do NOT edit this file!
+class=org.apache.camel.model.Resilience4jConfigurationDefinitionConfigurer
diff --git
a/core/camel-core-engine/src/main/java/org/apache/camel/model/FaultToleranceConfigurationDefinition.java
b/core/camel-core-engine/src/main/java/org/apache/camel/model/FaultToleranceConfigurationDefinition.java
index 86c18d8..0144527 100644
---
a/core/camel-core-engine/src/main/java/org/apache/camel/model/FaultToleranceConfigurationDefinition.java
+++
b/core/camel-core-engine/src/main/java/org/apache/camel/model/FaultToleranceConfigurationDefinition.java
@@ -21,6 +21,7 @@ import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.bind.annotation.XmlTransient;
+import org.apache.camel.spi.Configurer;
import org.apache.camel.spi.Metadata;
/**
@@ -29,6 +30,7 @@ import org.apache.camel.spi.Metadata;
@Metadata(label = "eip,routing,circuitbreaker")
@XmlRootElement(name = "faultToleranceConfiguration")
@XmlAccessorType(XmlAccessType.FIELD)
+@Configurer
public class FaultToleranceConfigurationDefinition extends
FaultToleranceConfigurationCommon {
@XmlTransient
diff --git
a/core/camel-core-engine/src/main/java/org/apache/camel/model/HystrixConfigurationDefinition.java
b/core/camel-core-engine/src/main/java/org/apache/camel/model/HystrixConfigurationDefinition.java
index 7159849..1a08b07 100644
---
a/core/camel-core-engine/src/main/java/org/apache/camel/model/HystrixConfigurationDefinition.java
+++
b/core/camel-core-engine/src/main/java/org/apache/camel/model/HystrixConfigurationDefinition.java
@@ -23,6 +23,7 @@ import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.bind.annotation.XmlTransient;
+import org.apache.camel.spi.Configurer;
import org.apache.camel.spi.Metadata;
/**
@@ -31,6 +32,7 @@ import org.apache.camel.spi.Metadata;
@Metadata(label = "eip,routing,circuitbreaker")
@XmlRootElement(name = "hystrixConfiguration")
@XmlAccessorType(XmlAccessType.FIELD)
+@Configurer
public class HystrixConfigurationDefinition extends HystrixConfigurationCommon
{
public static final String DEFAULT_GROUP_KEY = "CamelHystrix";
diff --git
a/core/camel-core-engine/src/main/java/org/apache/camel/model/Resilience4jConfigurationDefinition.java
b/core/camel-core-engine/src/main/java/org/apache/camel/model/Resilience4jConfigurationDefinition.java
index 61c66fe..5fe404d 100644
---
a/core/camel-core-engine/src/main/java/org/apache/camel/model/Resilience4jConfigurationDefinition.java
+++
b/core/camel-core-engine/src/main/java/org/apache/camel/model/Resilience4jConfigurationDefinition.java
@@ -23,6 +23,7 @@ import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlRootElement;
import javax.xml.bind.annotation.XmlTransient;
+import org.apache.camel.spi.Configurer;
import org.apache.camel.spi.Metadata;
/**
@@ -31,6 +32,7 @@ import org.apache.camel.spi.Metadata;
@Metadata(label = "eip,routing,circuitbreaker")
@XmlRootElement(name = "resilience4jConfiguration")
@XmlAccessorType(XmlAccessType.FIELD)
+@Configurer
public class Resilience4jConfigurationDefinition extends
Resilience4jConfigurationCommon {
@XmlTransient
