You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by co...@apache.org on 2020/09/29 09:44:27 UTC
[camel] branch CAMEL-15591 created (now 2ce4c7e)
This is an automated email from the ASF dual-hosted git repository.
coheigea pushed a change to branch CAMEL-15591
in repository https://gitbox.apache.org/repos/asf/camel.git.
at 2ce4c7e CAMEL-15591 - Put a configurable limit on the size of unzipped data using camel-zipfile + camel-tarfile
This branch includes the following new commits:
new 2ce4c7e CAMEL-15591 - Put a configurable limit on the size of unzipped data using camel-zipfile + camel-tarfile
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel] 01/01: CAMEL-15591 - Put a configurable limit on the size
of unzipped data using camel-zipfile + camel-tarfile
Posted by co...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
coheigea pushed a commit to branch CAMEL-15591
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 2ce4c7efb3f0b0e9471247d2be4411aea67367d4
Author: Colm O hEigeartaigh <co...@apache.org>
AuthorDate: Tue Sep 29 10:43:46 2020 +0100
CAMEL-15591 - Put a configurable limit on the size of unzipped data using camel-zipfile + camel-tarfile
---
.../apache/camel/catalog/docs/aggregate-eip.adoc | 9 +++---
.../camel/catalog/docs/batch-config-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/bean-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/choice-eip.adoc | 1 +
.../camel/catalog/docs/circuitBreaker-eip.adoc | 1 +
.../apache/camel/catalog/docs/claimCheck-eip.adoc | 1 +
.../camel/catalog/docs/convertBodyTo-eip.adoc | 1 +
.../camel/catalog/docs/customLoadBalancer-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/delay-eip.adoc | 1 +
.../camel/catalog/docs/dynamicRouter-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/enrich-eip.adoc | 1 +
.../apache/camel/catalog/docs/failover-eip.adoc | 1 +
.../docs/faultToleranceConfiguration-eip.adoc | 3 +-
.../org/apache/camel/catalog/docs/filter-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/from-eip.adoc | 1 +
.../catalog/docs/hystrixConfiguration-eip.adoc | 33 +++++++++++-----------
.../camel/catalog/docs/idempotentConsumer-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/inOnly-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/inOut-eip.adoc | 1 +
.../apache/camel/catalog/docs/loadBalance-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/log-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/loop-eip.adoc | 1 +
.../apache/camel/catalog/docs/multicast-eip.adoc | 1 +
.../apache/camel/catalog/docs/onFallback-eip.adoc | 1 +
.../apache/camel/catalog/docs/otherwise-eip.adoc | 1 +
.../apache/camel/catalog/docs/pipeline-eip.adoc | 1 +
.../apache/camel/catalog/docs/pollEnrich-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/process-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/random-eip.adoc | 1 +
.../camel/catalog/docs/recipientList-eip.adoc | 1 +
.../camel/catalog/docs/removeHeader-eip.adoc | 1 +
.../camel/catalog/docs/removeHeaders-eip.adoc | 1 +
.../camel/catalog/docs/removeProperties-eip.adoc | 1 +
.../camel/catalog/docs/removeProperty-eip.adoc | 1 +
.../apache/camel/catalog/docs/resequence-eip.adoc | 1 +
.../docs/resilience4jConfiguration-eip.adoc | 9 +++---
.../apache/camel/catalog/docs/rollback-eip.adoc | 1 +
.../apache/camel/catalog/docs/roundRobin-eip.adoc | 1 +
.../apache/camel/catalog/docs/routingSlip-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/saga-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/sample-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/script-eip.adoc | 1 +
.../apache/camel/catalog/docs/serviceCall-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/setBody-eip.adoc | 1 +
.../apache/camel/catalog/docs/setHeader-eip.adoc | 1 +
.../apache/camel/catalog/docs/setProperty-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/sort-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/split-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/step-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/sticky-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/stop-eip.adoc | 1 +
.../camel/catalog/docs/stream-config-eip.adoc | 1 +
.../camel/catalog/docs/tarfile-dataformat.adoc | 3 +-
.../org/apache/camel/catalog/docs/threads-eip.adoc | 3 +-
.../apache/camel/catalog/docs/throttle-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/to-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/toD-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/topic-eip.adoc | 1 +
.../apache/camel/catalog/docs/transform-eip.adoc | 1 +
.../apache/camel/catalog/docs/validate-eip.adoc | 1 +
.../apache/camel/catalog/docs/weighted-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/when-eip.adoc | 1 +
.../org/apache/camel/catalog/docs/wireTap-eip.adoc | 1 +
.../camel/catalog/docs/zipfile-dataformat.adoc | 3 +-
.../tarfile/TarFileDataFormatConfigurer.java | 2 ++
.../apache/camel/dataformat/tarfile/tarfile.json | 1 +
.../src/main/docs/tarfile-dataformat.adoc | 3 +-
.../dataformat/tarfile/TarFileDataFormat.java | 15 +++++++++-
.../zipfile/ZipFileDataFormatConfigurer.java | 2 ++
.../apache/camel/dataformat/zipfile/zipfile.json | 1 +
.../src/main/docs/zipfile-dataformat.adoc | 3 +-
.../dataformat/zipfile/ZipFileDataFormat.java | 15 +++++++++-
.../org/apache/camel/model/dataformat/tarfile.json | 1 +
.../org/apache/camel/model/dataformat/zipfile.json | 1 +
.../camel/model/dataformat/TarFileDataFormat.java | 19 +++++++++++++
.../camel/model/dataformat/ZipFileDataFormat.java | 17 +++++++++++
.../dataformat/TarFileDataFormatReifier.java | 1 +
.../dataformat/ZipFileDataFormatReifier.java | 1 +
.../main/java/org/apache/camel/util/IOHelper.java | 9 ++++++
.../java/org/apache/camel/xml/in/ModelParser.java | 2 ++
.../dataformats/pages/tarfile-dataformat.adoc | 3 +-
.../dataformats/pages/zipfile-dataformat.adoc | 3 +-
82 files changed, 185 insertions(+), 34 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aggregate-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aggregate-eip.adoc
index a2f1901..6fad7eb 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aggregate-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aggregate-eip.adoc
@@ -4,6 +4,7 @@
:description: Aggregates many messages into a single message
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/aggregate.adoc[]
The
http://www.enterpriseintegrationpatterns.com/Aggregator.html[Aggregator]
@@ -34,7 +35,7 @@ The Aggregate EIP supports 27 options which are listed below:
| *parallelProcessing* | 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. | false | Boolean
| *optimisticLocking* | Turns on using optimistic locking, which requires the aggregationRepository being used, is supporting this by implementing org.apache.camel.spi.OptimisticLockingAggregationRepository . | false | Boolean
| *executorServiceRef* | If using parallelProcessing you can specify a custom thread pool to be used. In fact also if you are not using parallelProcessing this custom thread pool is used to send out aggregated exchanges as well. | | String
-| *timeoutCheckerExecutorService Ref* | If using either of the completionTimeout, completionTimeoutExpression, or completionInterval options a background thread is created to check for the completion for every aggregator. Set this option to provide a custom thread pool to be used rather than creating a new thread for every aggregator. | | String
+| *timeoutCheckerExecutorService{zwsp}Ref* | If using either of the completionTimeout, completionTimeoutExpression, or completionInterval options a background thread is created to check for the completion for every aggregator. Set this option to provide a custom thread pool to be used rather than creating a new thread for every aggregator. | | String
| *aggregationRepositoryRef* | Sets the custom aggregate repository to use. Will by default use org.apache.camel.processor.aggregate.MemoryAggregationRepository | | String
| *strategyRef* | A reference to lookup the AggregationStrategy in the Registry. Configuring an AggregationStrategy is required, and is used to merge the incoming Exchange with the existing already merged exchanges. At first call the oldExchange parameter is null. On subsequent invocations the oldExchange contains the merged exchanges and newExchange is of course the new incoming Exchange. | | String
| *strategyMethodName* | This option can be used to explicit declare the method name to use, when using POJOs as the AggregationStrategy. | | String
@@ -42,12 +43,12 @@ The Aggregate EIP supports 27 options which are listed below:
| *completionSize* | Number of messages aggregated before the aggregation is complete. This option can be set as either a fixed value or using an Expression which allows you to evaluate a size dynamically - will use Integer as result. If both are set Camel will fallback to use the fixed value if the Expression result was null or 0. | | Integer
| *completionInterval* | A repeating period in millis by which the aggregator will complete all current aggregated exchanges. Camel has a background task which is triggered every period. You cannot use this option together with completionTimeout, only one of them can be used. | | String
| *completionTimeout* | Time in millis that an aggregated exchange should be inactive before its complete (timeout). This option can be set as either a fixed value or using an Expression which allows you to evaluate a timeout dynamically - will use Long as result. If both are set Camel will fallback to use the fixed value if the Expression result was null or 0. You cannot use this option together with completionInterval, only one of the two can be used. By default the timeout checker run [...]
-| *completionTimeoutChecker Interval* | Interval in millis that is used by the background task that checks for timeouts ( org.apache.camel.TimeoutMap ). By default the timeout checker runs every second. The timeout is an approximation and there is no guarantee that the a timeout is triggered exactly after the timeout value. It is not recommended to use very low timeout values or checker intervals. | 1s | String
+| *completionTimeoutChecker{zwsp}Interval* | Interval in millis that is used by the background task that checks for timeouts ( org.apache.camel.TimeoutMap ). By default the timeout checker runs every second. The timeout is an approximation and there is no guarantee that the a timeout is triggered exactly after the timeout value. It is not recommended to use very low timeout values or checker intervals. | 1s | String
| *completionFromBatchConsumer* | Enables the batch completion mode where we aggregate from a org.apache.camel.BatchConsumer and aggregate the total number of exchanges the org.apache.camel.BatchConsumer has reported as total by checking the exchange property org.apache.camel.Exchange#BATCH_COMPLETE when its complete. This option cannot be used together with discardOnAggregationFailure. | false | Boolean
-| *completionOnNewCorrelation Group* | Enables completion on all previous groups when a new incoming correlation group. This can for example be used to complete groups with same correlation keys when they are in consecutive order. Notice when this is enabled then only 1 correlation group can be in progress as when a new correlation group starts, then the previous groups is forced completed. | false | Boolean
+| *completionOnNewCorrelation{zwsp}Group* | Enables completion on all previous groups when a new incoming correlation group. This can for example be used to complete groups with same correlation keys when they are in consecutive order. Notice when this is enabled then only 1 correlation group can be in progress as when a new correlation group starts, then the previous groups is forced completed. | false | Boolean
| *eagerCheckCompletion* | Use eager completion checking which means that the completionPredicate will use the incoming Exchange. As opposed to without eager completion checking the completionPredicate will use the aggregated Exchange. | false | Boolean
| *ignoreInvalidCorrelationKeys* | If a correlation key cannot be successfully evaluated it will be ignored by logging a DEBUG and then just ignore the incoming Exchange. | false | Boolean
-| *closeCorrelationKeyOn Completion* | Closes a correlation key when its complete. Any late received exchanges which has a correlation key that has been closed, it will be defined and a ClosedCorrelationKeyException is thrown. | | Integer
+| *closeCorrelationKeyOn{zwsp}Completion* | Closes a correlation key when its complete. Any late received exchanges which has a correlation key that has been closed, it will be defined and a ClosedCorrelationKeyException is thrown. | | Integer
| *discardOnCompletionTimeout* | Discards the aggregated message on completion timeout. This means on timeout the aggregated message is dropped and not sent out of the aggregator. | false | Boolean
| *discardOnAggregationFailure* | Discards the aggregated message when aggregation failed (an exception was thrown from AggregationStrategy . This means the partly aggregated message is dropped and not sent out of the aggregator. This option cannot be used together with completionFromBatchConsumer. | false | Boolean
| *forceCompletionOnStop* | Indicates to complete all current aggregated exchanges when the context is stopped | false | Boolean
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/batch-config-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/batch-config-eip.adoc
index b1e6bc9..b924f52 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/batch-config-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/batch-config-eip.adoc
@@ -4,6 +4,7 @@
:description: Configures batch-processing resequence eip.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/batch-config.adoc[]
Batch-processing resequence EIP
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/bean-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/bean-eip.adoc
index c6e7b53..1542b74 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/bean-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/bean-eip.adoc
@@ -4,6 +4,7 @@
:description: Calls a java bean
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/bean.adoc[]
The Bean EIP binds beans to Camel message exchanges.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/choice-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/choice-eip.adoc
index 9000a01..5875f2b 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/choice-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/choice-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes messages based on a series of predicates
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/choice.adoc[]
The
http://www.enterpriseintegrationpatterns.com/ContentBasedRouter.html[Content
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/circuitBreaker-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/circuitBreaker-eip.adoc
index 95e8fc0..0e6588d 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/circuitBreaker-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/circuitBreaker-eip.adoc
@@ -4,6 +4,7 @@
:description: null
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/circuitBreaker.adoc[]
The Circuit Breaker pattern is inspired by the real-world electrical circuit breaker,
which is used to detect excessive current draw and fail fast to protect electrical equipment.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/claimCheck-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/claimCheck-eip.adoc
index 6b0438c..10ff54e 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/claimCheck-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/claimCheck-eip.adoc
@@ -4,6 +4,7 @@
:description: The Claim Check EIP allows you to replace message content with a claim check (a unique key), which can be used to retrieve the message content at a later time.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/claimCheck.adoc[]
The http://www.enterpriseintegrationpatterns.com/patterns/messaging/StoreInLibrary.html[Claim Check] from the xref:enterprise-integration-patterns.adoc[EIP patterns]
allows you to replace message content with a claim check (a unique key), which can be used to retrieve the message content at a later time.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/convertBodyTo-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/convertBodyTo-eip.adoc
index b273146..c55bb08 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/convertBodyTo-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/convertBodyTo-eip.adoc
@@ -4,6 +4,7 @@
:description: Converts the message body to another type
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/convertBodyTo.adoc[]
The ConvertBodyTo EIP allows you to transform your body to a different type.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/customLoadBalancer-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/customLoadBalancer-eip.adoc
index 16215a2..5730bd1 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/customLoadBalancer-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/customLoadBalancer-eip.adoc
@@ -4,6 +4,7 @@
:description: Custom load balancer
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/customLoadBalancer.adoc[]
This EIP allows you to use your own Load Balancer implementation
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/delay-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/delay-eip.adoc
index a667a51..402a1eb 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/delay-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/delay-eip.adoc
@@ -4,6 +4,7 @@
:description: Delays processing for a specified length of time
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/delay.adoc[]
== Options
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/dynamicRouter-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/dynamicRouter-eip.adoc
index e5bc5ce..007b14b 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/dynamicRouter-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/dynamicRouter-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes messages based on dynamic rules
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/dynamicRouter.adoc[]
The
http://www.enterpriseintegrationpatterns.com/DynamicRouter.html[Dynamic
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/enrich-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/enrich-eip.adoc
index 8334443..6972739 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/enrich-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/enrich-eip.adoc
@@ -4,6 +4,7 @@
:description: Enriches a message with data from a secondary resource
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/enrich.adoc[]
Camel supports the Content Enricher from the EIP patterns using a Message Translator, an arbitrary Processor in the routing logic, or using the enrich DSL element to enrich the message.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/failover-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/failover-eip.adoc
index 37ee085..6d4f552 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/failover-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/failover-eip.adoc
@@ -4,6 +4,7 @@
:description: Failover load balancer The failover load balancer is capable of trying the next processor in case an Exchange failed with an exception during processing. You can constrain the failover to activate only when one exception of a list you specify occurs. If you do not specify a list any exception will cause fail over to occur. This balancer uses the same strategy for matching exceptions as the Exception Clause does for the onException.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/failover.adoc[]
Failover Load Balancer, with this policy in case of failures the exchange will be tried on the next endpoint.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/faultToleranceConfiguration-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/faultToleranceConfiguration-eip.adoc
index 107bbe9..91dc9f3 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/faultToleranceConfiguration-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/faultToleranceConfiguration-eip.adoc
@@ -4,6 +4,7 @@
:description: MicroProfile Fault Tolerance Circuit Breaker EIP configuration
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/faultToleranceConfiguration.adoc[]
// eip options: START
@@ -20,7 +21,7 @@ The Fault Tolerance Configuration EIP supports 13 options which are listed below
| *timeoutEnabled* | Whether timeout is enabled or not on the circuit breaker. Default is false. | false | Boolean
| *timeoutDuration* | Configures the thread execution timeout. Default value is 1 second. | 1s | String
| *timeoutPoolSize* | Configures the pool size of the thread pool when timeout is enabled. Default value is 10. | 10 | Integer
-| *timeoutScheduledExecutor ServiceRef* | References to a custom thread pool to use when timeout is enabled | | String
+| *timeoutScheduledExecutor{zwsp}ServiceRef* | References to a custom thread pool to use when timeout is enabled | | String
| *bulkheadEnabled* | Whether bulkhead is enabled or not on the circuit breaker. Default is false. | false | Boolean
| *bulkheadMaxConcurrentCalls* | Configures the max amount of concurrent calls the bulkhead will support. | 10 | Integer
| *bulkheadWaitingTaskQueue* | Configures the task queue size for holding waiting tasks to be processed by the bulkhead. | 10 | Integer
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/filter-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/filter-eip.adoc
index ad43501..2042d6f 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/filter-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/filter-eip.adoc
@@ -4,6 +4,7 @@
:description: Filter out messages based using a predicate
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/filter.adoc[]
The http://www.enterpriseintegrationpatterns.com/Filter.html[Message
Filter] from the xref:enterprise-integration-patterns.adoc[EIP patterns]
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/from-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/from-eip.adoc
index c87052a..efce5e3 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/from-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/from-eip.adoc
@@ -4,6 +4,7 @@
:description: Act as a message source as input to a route
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/from.adoc[]
== Options
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hystrixConfiguration-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hystrixConfiguration-eip.adoc
index 99b094d..077eb40 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hystrixConfiguration-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/hystrixConfiguration-eip.adoc
@@ -5,6 +5,7 @@
:since:
:supportLevel: Stable-deprecated
:deprecated: *deprecated*
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/hystrixConfiguration.adoc[]
// eip options: START
@@ -16,33 +17,33 @@ The Hystrix Configuration EIP supports 31 options which are listed below:
| *groupKey* | Sets the group key to use. The default value is CamelHystrix. | CamelHystrix | String
| *threadPoolKey* | Sets the thread pool key to use. Will by default use the same value as groupKey has been configured to use. | CamelHystrix | String
| *circuitBreakerEnabled* | Whether to use a HystrixCircuitBreaker or not. If false no circuit-breaker logic will be used and all requests permitted. This is similar in effect to circuitBreakerForceClosed() except that continues tracking metrics and knowing whether it should be open/closed, this property results in not even instantiating a circuit-breaker. | true | Boolean
-| *circuitBreakerErrorThreshold Percentage* | Error percentage threshold (as whole number such as 50) at which point the circuit breaker will trip open and reject requests. It will stay tripped for the duration defined in circuitBreakerSleepWindowInMilliseconds; The error percentage this is compared against comes from HystrixCommandMetrics.getHealthCounts(). | 50 | Integer
+| *circuitBreakerErrorThreshold{zwsp}Percentage* | Error percentage threshold (as whole number such as 50) at which point the circuit breaker will trip open and reject requests. It will stay tripped for the duration defined in circuitBreakerSleepWindowInMilliseconds; The error percentage this is compared against comes from HystrixCommandMetrics.getHealthCounts(). | 50 | Integer
| *circuitBreakerForceClosed* | If true the HystrixCircuitBreaker#allowRequest() will always return true to allow requests regardless of the error percentage from HystrixCommandMetrics.getHealthCounts(). The circuitBreakerForceOpen() property takes precedence so if it set to true this property does nothing. | false | Boolean
| *circuitBreakerForceOpen* | If true the HystrixCircuitBreaker.allowRequest() will always return false, causing the circuit to be open (tripped) and reject all requests. This property takes precedence over circuitBreakerForceClosed(); | false | Boolean
-| *circuitBreakerRequestVolume Threshold* | Minimum number of requests in the metricsRollingStatisticalWindowInMilliseconds() that must exist before the HystrixCircuitBreaker will trip. If below this number the circuit will not trip regardless of error percentage. | 20 | Integer
-| *circuitBreakerSleepWindowIn Milliseconds* | The time in milliseconds after a HystrixCircuitBreaker trips open that it should wait before trying requests again. | 5000 | Integer
-| *executionIsolationSemaphoreMax ConcurrentRequests* | Number of concurrent requests permitted to HystrixCommand.run(). Requests beyond the concurrent limit will be rejected. Applicable only when executionIsolationStrategy == SEMAPHORE. | 20 | Integer
+| *circuitBreakerRequestVolume{zwsp}Threshold* | Minimum number of requests in the metricsRollingStatisticalWindowInMilliseconds() that must exist before the HystrixCircuitBreaker will trip. If below this number the circuit will not trip regardless of error percentage. | 20 | Integer
+| *circuitBreakerSleepWindowIn{zwsp}Milliseconds* | The time in milliseconds after a HystrixCircuitBreaker trips open that it should wait before trying requests again. | 5000 | Integer
+| *executionIsolationSemaphoreMax{zwsp}ConcurrentRequests* | Number of concurrent requests permitted to HystrixCommand.run(). Requests beyond the concurrent limit will be rejected. Applicable only when executionIsolationStrategy == SEMAPHORE. | 20 | Integer
| *executionIsolationStrategy* | What isolation strategy HystrixCommand.run() will be executed with. If THREAD then it will be executed on a separate thread and concurrent requests limited by the number of threads in the thread-pool. If SEMAPHORE then it will be executed on the calling thread and concurrent requests limited by the semaphore count. | THREAD | String
-| *executionIsolationThread InterruptOnTimeout* | Whether the execution thread should attempt an interrupt (using Future#cancel ) when a thread times out. Applicable only when executionIsolationStrategy() == THREAD. | true | Boolean
+| *executionIsolationThread{zwsp}InterruptOnTimeout* | Whether the execution thread should attempt an interrupt (using Future#cancel ) when a thread times out. Applicable only when executionIsolationStrategy() == THREAD. | true | Boolean
| *executionTimeoutInMilliseconds* | Time in milliseconds at which point the command will timeout and halt execution. If executionIsolationThreadInterruptOnTimeout == true and the command is thread-isolated, the executing thread will be interrupted. If the command is semaphore-isolated and a HystrixObservableCommand, that command will get unsubscribed. | 1000 | Integer
| *executionTimeoutEnabled* | Whether the timeout mechanism is enabled for this command | true | Boolean
-| *fallbackIsolationSemaphoreMax ConcurrentRequests* | Number of concurrent requests permitted to HystrixCommand.getFallback(). Requests beyond the concurrent limit will fail-fast and not attempt retrieving a fallback. | 10 | Integer
+| *fallbackIsolationSemaphoreMax{zwsp}ConcurrentRequests* | Number of concurrent requests permitted to HystrixCommand.getFallback(). Requests beyond the concurrent limit will fail-fast and not attempt retrieving a fallback. | 10 | Integer
| *fallbackEnabled* | Whether HystrixCommand.getFallback() should be attempted when failure occurs. | true | Boolean
-| *metricsHealthSnapshotInterval InMilliseconds* | Time in milliseconds to wait between allowing health snapshots to be taken that calculate success and error percentages and affect HystrixCircuitBreaker.isOpen() status. On high-volume circuits the continual calculation of error percentage can become CPU intensive thus this controls how often it is calculated. | 500 | Integer
-| *metricsRollingPercentileBucket Size* | Maximum number of values stored in each bucket of the rolling percentile. This is passed into HystrixRollingPercentile inside HystrixCommandMetrics. | 10 | Integer
-| *metricsRollingPercentile Enabled* | Whether percentile metrics should be captured using HystrixRollingPercentile inside HystrixCommandMetrics. | true | Boolean
-| *metricsRollingPercentileWindow InMilliseconds* | Duration of percentile rolling window in milliseconds. This is passed into HystrixRollingPercentile inside HystrixCommandMetrics. | 10000 | Integer
-| *metricsRollingPercentileWindow Buckets* | Number of buckets the rolling percentile window is broken into. This is passed into HystrixRollingPercentile inside HystrixCommandMetrics. | 6 | Integer
-| *metricsRollingStatistical WindowInMilliseconds* | This property sets the duration of the statistical rolling window, in milliseconds. This is how long metrics are kept for the thread pool. The window is divided into buckets and rolls by those increments. | 10000 | Integer
-| *metricsRollingStatistical WindowBuckets* | Number of buckets the rolling statistical window is broken into. This is passed into HystrixRollingNumber inside HystrixCommandMetrics. | 10 | Integer
+| *metricsHealthSnapshotInterval{zwsp}InMilliseconds* | Time in milliseconds to wait between allowing health snapshots to be taken that calculate success and error percentages and affect HystrixCircuitBreaker.isOpen() status. On high-volume circuits the continual calculation of error percentage can become CPU intensive thus this controls how often it is calculated. | 500 | Integer
+| *metricsRollingPercentileBucket{zwsp}Size* | Maximum number of values stored in each bucket of the rolling percentile. This is passed into HystrixRollingPercentile inside HystrixCommandMetrics. | 10 | Integer
+| *metricsRollingPercentile{zwsp}Enabled* | Whether percentile metrics should be captured using HystrixRollingPercentile inside HystrixCommandMetrics. | true | Boolean
+| *metricsRollingPercentileWindow{zwsp}InMilliseconds* | Duration of percentile rolling window in milliseconds. This is passed into HystrixRollingPercentile inside HystrixCommandMetrics. | 10000 | Integer
+| *metricsRollingPercentileWindow{zwsp}Buckets* | Number of buckets the rolling percentile window is broken into. This is passed into HystrixRollingPercentile inside HystrixCommandMetrics. | 6 | Integer
+| *metricsRollingStatistical{zwsp}WindowInMilliseconds* | This property sets the duration of the statistical rolling window, in milliseconds. This is how long metrics are kept for the thread pool. The window is divided into buckets and rolls by those increments. | 10000 | Integer
+| *metricsRollingStatistical{zwsp}WindowBuckets* | Number of buckets the rolling statistical window is broken into. This is passed into HystrixRollingNumber inside HystrixCommandMetrics. | 10 | Integer
| *requestLogEnabled* | Whether HystrixCommand execution and events should be logged to HystrixRequestLog. | true | Boolean
| *corePoolSize* | Core thread-pool size that gets passed to java.util.concurrent.ThreadPoolExecutor#setCorePoolSize(int) | 10 | Integer
| *maximumSize* | Maximum thread-pool size that gets passed to ThreadPoolExecutor#setMaximumPoolSize(int) . This is the maximum amount of concurrency that can be supported without starting to reject HystrixCommands. Please note that this setting only takes effect if you also set allowMaximumSizeToDivergeFromCoreSize | 10 | Integer
| *keepAliveTime* | Keep-alive time in minutes that gets passed to ThreadPoolExecutor#setKeepAliveTime(long,TimeUnit) | 1 | Integer
| *maxQueueSize* | Max queue size that gets passed to BlockingQueue in HystrixConcurrencyStrategy.getBlockingQueue(int) This should only affect the instantiation of a threadpool - it is not eliglible to change a queue size on the fly. For that, use queueSizeRejectionThreshold(). | -1 | Integer
| *queueSizeRejectionThreshold* | Queue size rejection threshold is an artificial max size at which rejections will occur even if maxQueueSize has not been reached. This is done because the maxQueueSize of a BlockingQueue can not be dynamically changed and we want to support dynamically changing the queue size that affects rejections. This is used by HystrixCommand when queuing a thread for execution. | 5 | Integer
-| *threadPoolRollingNumber StatisticalWindowIn Milliseconds* | Duration of statistical rolling window in milliseconds. This is passed into HystrixRollingNumber inside each HystrixThreadPoolMetrics instance. | 10000 | Integer
-| *threadPoolRollingNumber StatisticalWindowBuckets* | Number of buckets the rolling statistical window is broken into. This is passed into HystrixRollingNumber inside each HystrixThreadPoolMetrics instance. | 10 | Integer
-| *allowMaximumSizeToDivergeFrom CoreSize* | Allows the configuration for maximumSize to take effect. That value can then be equal to, or higher, than coreSize | false | Boolean
+| *threadPoolRollingNumber{zwsp}StatisticalWindowIn{zwsp}Milliseconds* | Duration of statistical rolling window in milliseconds. This is passed into HystrixRollingNumber inside each HystrixThreadPoolMetrics instance. | 10000 | Integer
+| *threadPoolRollingNumber{zwsp}StatisticalWindowBuckets* | Number of buckets the rolling statistical window is broken into. This is passed into HystrixRollingNumber inside each HystrixThreadPoolMetrics instance. | 10 | Integer
+| *allowMaximumSizeToDivergeFrom{zwsp}CoreSize* | Allows the configuration for maximumSize to take effect. That value can then be equal to, or higher, than coreSize | false | Boolean
|===
// eip options: END
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/idempotentConsumer-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/idempotentConsumer-eip.adoc
index 553d553..fa57757 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/idempotentConsumer-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/idempotentConsumer-eip.adoc
@@ -4,6 +4,7 @@
:description: Filters out duplicate messages
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/idempotentConsumer.adoc[]
The
http://www.enterpriseintegrationpatterns.com/IdempotentReceiver.html[Idempotent
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOnly-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOnly-eip.adoc
index c8a9bca..0bb8509 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOnly-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOnly-eip.adoc
@@ -5,6 +5,7 @@
:since:
:supportLevel: Stable-deprecated
:deprecated: *deprecated*
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/inOnly.adoc[]
The *inOnly:* EIP define an InOnly ExchangePattern.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOut-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOut-eip.adoc
index 081016b..03abdd5 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOut-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/inOut-eip.adoc
@@ -5,6 +5,7 @@
:since:
:supportLevel: Stable-deprecated
:deprecated: *deprecated*
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/inOut.adoc[]
The *inOut:* EIP define an InOut ExchangePattern.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loadBalance-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loadBalance-eip.adoc
index 76168d9..36146a2 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loadBalance-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loadBalance-eip.adoc
@@ -4,6 +4,7 @@
:description: Balances message processing among a number of nodes
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/loadBalance.adoc[]
The Load Balancer Pattern allows you to delegate to one of a number of endpoints using a variety of different load balancing policies.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/log-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/log-eip.adoc
index 26c2817f..5632bb5 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/log-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/log-eip.adoc
@@ -4,6 +4,7 @@
:description: Logs the defined message to the logger
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/log.adoc[]
How can I log the processing of a xref:message.adoc[Message]?
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loop-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loop-eip.adoc
index 3cdc608..6f46a96 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loop-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/loop-eip.adoc
@@ -4,6 +4,7 @@
:description: Processes a message multiple times
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/loop.adoc[]
The Loop allows for processing a message a number of times, possibly in a different way for each iteration. Useful mostly during testing.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/multicast-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/multicast-eip.adoc
index bc5ae8a..5ad0fda 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/multicast-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/multicast-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes the same message to multiple paths either sequentially or in parallel.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/multicast.adoc[]
The Multicast EIP allows to route the same message to a number of endpoints
and process them in a different way. The main difference between the
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/onFallback-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/onFallback-eip.adoc
index c559197..40340dd 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/onFallback-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/onFallback-eip.adoc
@@ -4,6 +4,7 @@
:description: Route to be executed when Hystrix EIP executes fallback
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/onFallback.adoc[]
If you are using *onFallback* then that is intended to be local processing only where you can do a message transformation or call a bean or something as the fallback.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/otherwise-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/otherwise-eip.adoc
index 87d22a5..e875f9f 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/otherwise-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/otherwise-eip.adoc
@@ -4,6 +4,7 @@
:description: Route to be executed when all other choices evaluate to false
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/otherwise.adoc[]
The Otherwise EIP is related to http://www.enterpriseintegrationpatterns.com/ContentBasedRouter.html[Content
Based Router] from the xref:enterprise-integration-patterns.adoc[EIP
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pipeline-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pipeline-eip.adoc
index 0414588..cf6dcca 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pipeline-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pipeline-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes the message to a sequence of processors.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/pipeline.adoc[]
Camel supports the http://www.enterpriseintegrationpatterns.com/PipesAndFilters.html[Pipes and Filters] from the xref:enterprise-integration-patterns.adoc[EIP patterns] in various ways.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pollEnrich-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pollEnrich-eip.adoc
index 5c1178c..0a65db1 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pollEnrich-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/pollEnrich-eip.adoc
@@ -4,6 +4,7 @@
:description: Enriches messages with data polled from a secondary resource
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/pollEnrich.adoc[]
Camel comes with flavor `pollEnrich` as a choice of content enricher in the DSL.
The other one is `enrich`
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/process-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/process-eip.adoc
index c7807cf..86a4f91 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/process-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/process-eip.adoc
@@ -4,6 +4,7 @@
:description: Calls a Camel processor
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/process.adoc[]
The http://camel.apache.org/maven/current/camel-core/apidocs/org/apache/camel/Processor.html[Processor] interface is used to implement consumers of message exchanges or to implement a xref:message-translator.adoc[Message Translator]
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/random-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/random-eip.adoc
index 0134a5f..55b6658 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/random-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/random-eip.adoc
@@ -4,6 +4,7 @@
:description: Random load balancer The random load balancer selects a random endpoint for each exchange.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/random.adoc[]
// eip options: START
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/recipientList-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/recipientList-eip.adoc
index a74a469..6277f20 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/recipientList-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/recipientList-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes messages to a number of dynamically specified recipients (dynamic to)
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/recipientList.adoc[]
image::eip/RecipientList.gif[image]
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeader-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeader-eip.adoc
index a389bda..9dbc8e8 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeader-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeader-eip.adoc
@@ -4,6 +4,7 @@
:description: Removes a named header from the message
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/removeHeader.adoc[]
== Options
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeaders-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeaders-eip.adoc
index 4a2b4a4..374143d 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeaders-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeHeaders-eip.adoc
@@ -4,6 +4,7 @@
:description: Removes message headers whose name matches a specified pattern
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/removeHeaders.adoc[]
== Options
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperties-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperties-eip.adoc
index b019983..d6c192a 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperties-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperties-eip.adoc
@@ -4,6 +4,7 @@
:description: Removes message exchange properties whose name matches a specified pattern
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/removeProperties.adoc[]
The RemoveProperties EIP allows you to remove Properties from you exchange.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperty-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperty-eip.adoc
index 3e6b4f8..5696c77 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperty-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/removeProperty-eip.adoc
@@ -4,6 +4,7 @@
:description: Removes a named property from the message exchange
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/removeProperty.adoc[]
The RemoveProperty EIP allows you to remove a Property from your exchange.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resequence-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resequence-eip.adoc
index cc40f9a..5c469a8 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resequence-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resequence-eip.adoc
@@ -4,6 +4,7 @@
:description: Resequences (re-order) messages based on an expression
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/resequence.adoc[]
The http://www.enterpriseintegrationpatterns.com/Resequencer.html[Resequencer] from the https://camel.apache.org/enterprise-integration-patterns.html[EIP patterns] allows you to reorganise messages based on some comparator. +
By default in Camel we use an Expression to create the comparator; so that you can compare by a message header or the body or a piece of a message etc.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resilience4jConfiguration-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resilience4jConfiguration-eip.adoc
index 346b71e..7cfb063 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resilience4jConfiguration-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/resilience4jConfiguration-eip.adoc
@@ -4,6 +4,7 @@
:description: Resilience4j Circuit Breaker EIP configuration
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/resilience4jConfiguration.adoc[]
// eip options: START
@@ -15,14 +16,14 @@ The Resilience4j Configuration EIP supports 12 options which are listed below:
| *circuitBreakerRef* | Refers to an existing io.github.resilience4j.circuitbreaker.CircuitBreaker instance to lookup and use from the registry. When using this, then any other circuit breaker options are not in use. | | String
| *configRef* | Refers to an existing io.github.resilience4j.circuitbreaker.CircuitBreakerConfig instance to lookup and use from the registry. | | String
| *failureRateThreshold* | Configures the failure rate threshold in percentage. If the failure rate is equal or greater than the threshold the CircuitBreaker transitions to open and starts short-circuiting calls. The threshold must be greater than 0 and not greater than 100. Default value is 50 percentage. | 50 | Float
-| *permittedNumberOfCallsInHalf OpenState* | Configures the number of permitted calls when the CircuitBreaker is half open. The size must be greater than 0. Default size is 10. | 10 | Integer
+| *permittedNumberOfCallsInHalf{zwsp}OpenState* | Configures the number of permitted calls when the CircuitBreaker is half open. The size must be greater than 0. Default size is 10. | 10 | Integer
| *slidingWindowSize* | Configures the size of the sliding window which is used to record the outcome of calls when the CircuitBreaker is closed. slidingWindowSize configures the size of the sliding window. Sliding window can either be count-based or time-based. If slidingWindowType is COUNT_BASED, the last slidingWindowSize calls are recorded and aggregated. If slidingWindowType is TIME_BASED, the calls of the last slidingWindowSize seconds are recorded and aggregated. The slidingWindow [...]
| *slidingWindowType* | Configures the type of the sliding window which is used to record the outcome of calls when the CircuitBreaker is closed. Sliding window can either be count-based or time-based. If slidingWindowType is COUNT_BASED, the last slidingWindowSize calls are recorded and aggregated. If slidingWindowType is TIME_BASED, the calls of the last slidingWindowSize seconds are recorded and aggregated. Default slidingWindowType is COUNT_BASED. | COUNT_BASED | String
-| *minimumNumberOfCalls* | Configures configures the minimum number of calls which are required (per sliding window period) before the CircuitBreaker can calculate the error rate. For example, if minimumNumberOfCalls is 10, then at least 10 calls must be recorded, before the failure rate can be calculated. If only 9 calls have been recorded the CircuitBreaker will not transition to open even if all 9 calls have failed. Default minimumNumberOfCalls is 100 | 100 | Integer
+| *minimumNumberOfCalls* | Configures the minimum number of calls which are required (per sliding window period) before the CircuitBreaker can calculate the error rate. For example, if minimumNumberOfCalls is 10, then at least 10 calls must be recorded, before the failure rate can be calculated. If only 9 calls have been recorded the CircuitBreaker will not transition to open even if all 9 calls have failed. Default minimumNumberOfCalls is 100 | 100 | Integer
| *writableStackTraceEnabled* | Enables writable stack traces. When set to false, Exception.getStackTrace returns a zero length array. This may be used to reduce log spam when the circuit breaker is open as the cause of the exceptions is already known (the circuit breaker is short-circuiting calls). | true | Boolean
| *waitDurationInOpenState* | Configures the wait duration (in seconds) which specifies how long the CircuitBreaker should stay open, before it switches to half open. Default value is 60 seconds. | 60 | Integer
-| *automaticTransitionFromOpenTo HalfOpenEnabled* | Enables automatic transition from OPEN to HALF_OPEN state once the waitDurationInOpenState has passed. | false | Boolean
-| *slowCallRateThreshold* | Configures a threshold in percentage. The CircuitBreaker considers a call as slow when the call duration is greater than slowCallDurationThreshold(Duration. When the percentage of slow calls is equal or greater the threshold, the CircuitBreaker transitions to open and starts short-circuiting calls. The threshold must be greater than 0 and not greater than 100. Default value is 100 percentage which means that all recorded calls must be slower than slowCallDurat [...]
+| *automaticTransitionFromOpenTo{zwsp}HalfOpenEnabled* | Enables automatic transition from OPEN to HALF_OPEN state once the waitDurationInOpenState has passed. | false | Boolean
+| *slowCallRateThreshold* | Configures a threshold in percentage. The CircuitBreaker considers a call as slow when the call duration is greater than slowCallDurationThreshold Duration. When the percentage of slow calls is equal or greater the threshold, the CircuitBreaker transitions to open and starts short-circuiting calls. The threshold must be greater than 0 and not greater than 100. Default value is 100 percentage which means that all recorded calls must be slower than slowCallDurat [...]
| *slowCallDurationThreshold* | Configures the duration threshold (seconds) above which calls are considered as slow and increase the slow calls percentage. Default value is 60 seconds. | 60 | Integer
|===
// eip options: END
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/rollback-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/rollback-eip.adoc
index 28fa95d..52e9db4 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/rollback-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/rollback-eip.adoc
@@ -4,6 +4,7 @@
:description: Forces a rollback by stopping routing the message
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/rollback.adoc[]
Camel recommends supporting the
http://www.enterpriseintegrationpatterns.com/TransactionalClient.html[Transactional
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/roundRobin-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/roundRobin-eip.adoc
index 97c419d..2d22b9a 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/roundRobin-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/roundRobin-eip.adoc
@@ -4,6 +4,7 @@
:description: Round robin load balancer The round robin load balancer will use the next endpoint for each message. This load balancer is not meant to work with failover, for that you should use the dedicated failover load balancer.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/roundRobin.adoc[]
Round Robin Load Balancer. With this Load Balancing policy, a random endpoint is selected for each exchange.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/routingSlip-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/routingSlip-eip.adoc
index 1a0abcb..e78e2dc 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/routingSlip-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/routingSlip-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes a message through a series of steps that are pre-determined (the slip)
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/routingSlip.adoc[]
image::eip/RoutingTableSimple.gif[image]
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/saga-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/saga-eip.adoc
index 5bfb24e..991a69b 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/saga-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/saga-eip.adoc
@@ -4,6 +4,7 @@
:description: Enables sagas on the route
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/saga.adoc[]
The Saga EIP provides a way to define a series of related actions in a Camel route that should be either completed successfully (*all of them*) or not-executed/compensated.
Sagas implementations are able to coordinate *distributed services communicating using any transport* towards a globally *consistent outcome*.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sample-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sample-eip.adoc
index d8f7e76..cc62726 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sample-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sample-eip.adoc
@@ -4,6 +4,7 @@
:description: Extract a sample of the messages passing through a route
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/sample.adoc[]
A sampling throttler allows you to extract a sample of the exchanges from the traffic through a route. +
It is configured with a sampling period during which only a single exchange is allowed to pass through. All other exchanges will be stopped.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/script-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/script-eip.adoc
index 295c82f..a5c4233 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/script-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/script-eip.adoc
@@ -4,6 +4,7 @@
:description: Executes a script from a language which does not change the message body.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/script.adoc[]
Is used to execute a script which does not change the message (by default).
This is useful when you need to invoke some logic that are not in Java code such as JavaScript,
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/serviceCall-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/serviceCall-eip.adoc
index ef4fd2c..8d8fdf8 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/serviceCall-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/serviceCall-eip.adoc
@@ -4,6 +4,7 @@
:description: To call remote services
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/serviceCall.adoc[]
The Service Call EIP allows to call remote services in a distributed system.
The service to call is looked up in a service registry of some sorts such as Kubernetes, Consul, Etcd, Zookeeper, DNS.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setBody-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setBody-eip.adoc
index aa69e51..59ae73c 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setBody-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setBody-eip.adoc
@@ -4,6 +4,7 @@
:description: Sets the contents of the message body
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/setBody.adoc[]
The SetBody EIP allows you to set the body of your exchange.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setHeader-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setHeader-eip.adoc
index f86fe48..7c58288 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setHeader-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setHeader-eip.adoc
@@ -4,6 +4,7 @@
:description: Sets the value of a message header
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/setHeader.adoc[]
The SetHeader EIP allows you to set and header on your exchange.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setProperty-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setProperty-eip.adoc
index 2bfc3a2..4aa7f48 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setProperty-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/setProperty-eip.adoc
@@ -4,6 +4,7 @@
:description: Sets a named property on the message exchange
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/setProperty.adoc[]
The SetProperty EIP allows you to set a property on your exchange.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sort-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sort-eip.adoc
index 678286b..87b0947 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sort-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sort-eip.adoc
@@ -4,6 +4,7 @@
:description: Sorts the contents of the message
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/sort.adoc[]
Sort can be used to sort a message. Imagine you consume text files and before processing each file you want to be sure the content is sorted.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/split-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/split-eip.adoc
index 7449165..0a6d91d 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/split-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/split-eip.adoc
@@ -4,6 +4,7 @@
:description: Splits a single message into many sub-messages.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/split.adoc[]
The http://www.enterpriseintegrationpatterns.com/patterns/messaging/Sequencer.html[Splitter] from the xref:enterprise-integration-patterns.adoc[EIP patterns] allows you split a message into a number of pieces and process them individually.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/step-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/step-eip.adoc
index 52adc54..af6e011 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/step-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/step-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes the message to a sequence of processors which is grouped together as one logical name
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/step.adoc[]
Camel supports the http://www.enterpriseintegrationpatterns.com/PipesAndFilters.html[Pipes and Filters] from the xref:enterprise-integration-patterns.adoc[EIP patterns] in various ways.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sticky-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sticky-eip.adoc
index 63601b5..ece5d3c 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sticky-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/sticky-eip.adoc
@@ -4,6 +4,7 @@
:description: Sticky load balancer Sticky load balancing using an Expression to calculate a correlation key to perform the sticky load balancing; rather like jsessionid in the web or JMSXGroupID in JMS.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/sticky.adoc[]
Sticky Load Balancer. Sticky load balancing uses an Expression to calculate a correlation key to perform the sticky load balancing.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stop-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stop-eip.adoc
index 016671f..13d8a42 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stop-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stop-eip.adoc
@@ -4,6 +4,7 @@
:description: Stops the processing of the current message
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/stop.adoc[]
== Options
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stream-config-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stream-config-eip.adoc
index 58f9407..cbde7d6 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stream-config-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/stream-config-eip.adoc
@@ -4,6 +4,7 @@
:description: Configures stream-processing resequence eip.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/stream-config.adoc[]
Stream-processing resequence EIP
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/tarfile-dataformat.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/tarfile-dataformat.adoc
index 8b5e754..3c0bb20 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/tarfile-dataformat.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/tarfile-dataformat.adoc
@@ -21,7 +21,7 @@ aggregate multiple messages into a single Tar File.
// dataformat options: START
-The Tar File dataformat supports 4 options, which are listed below.
+The Tar File dataformat supports 5 options, which are listed below.
@@ -31,6 +31,7 @@ The Tar File dataformat supports 4 options, which are listed below.
| usingIterator | false | Boolean | If the tar file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode.
| allowEmptyDirectory | false | Boolean | If the tar file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty
| preservePathElements | false | Boolean | If the file name contains path elements, setting this option to true, allows the path to be maintained in the tar file.
+| maxDecompressedSize | | Long | Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size.
| contentTypeHeader | false | Boolean | Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application/xml for data formats marshalling to XML, or application/json for data formats marshalling to JSON etc.
|===
// dataformat options: END
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/threads-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/threads-eip.adoc
index 29e72cb..95eae22 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/threads-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/threads-eip.adoc
@@ -4,6 +4,7 @@
:description: Specifies that all steps after this node are processed asynchronously
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/threads.adoc[]
== Options
@@ -19,7 +20,7 @@ The Threads EIP supports 10 options which are listed below:
| *keepAliveTime* | Sets the keep alive time for idle threads | | Long
| *timeUnit* | Sets the keep alive time unit. By default SECONDS is used. | | TimeUnit
| *maxQueueSize* | Sets the maximum number of tasks in the work queue. Use -1 or Integer.MAX_VALUE for an unbounded queue | | Integer
-| *allowCoreThreadTimeOut* | Whether idle core threads is allowed to timeout and therefore can shrink the pool size below the core pool size Is by default false | false | Boolean
+| *allowCoreThreadTimeOut* | Whether idle core threads are allowed to timeout and therefore can shrink the pool size below the core pool size Is by default false | false | Boolean
| *threadName* | Sets the thread name to use. | Threads | String
| *rejectedPolicy* | Sets the handler for tasks which cannot be executed by the thread pool. | | ThreadPoolRejectedPolicy
| *callerRunsWhenRejected* | Whether or not to use as caller runs as fallback when a task is rejected being added to the thread pool (when its full). This is only used as fallback if no rejectedPolicy has been configured, or the thread pool has no configured rejection handler. Is by default true | true | String
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/throttle-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/throttle-eip.adoc
index ea40ca3..f0d89a2 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/throttle-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/throttle-eip.adoc
@@ -4,6 +4,7 @@
:description: Controls the rate at which messages are passed to the next node in the route
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/throttle.adoc[]
The Throttler Pattern allows you to ensure that a specific endpoint does not get overloaded, or that we don't exceed an agreed SLA with some external service.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/to-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/to-eip.adoc
index 48b50a1..b32e807 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/to-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/to-eip.adoc
@@ -4,6 +4,7 @@
:description: Sends the message to a static endpoint
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/to.adoc[]
See message related documentation
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/toD-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/toD-eip.adoc
index 4c45572..01cb596 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/toD-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/toD-eip.adoc
@@ -4,6 +4,7 @@
:description: Sends the message to a dynamic endpoint You can specify multiple languages in the uri separated by the plus sign, such as mock:language:xpath:/order/uri where mock: would be a prefix to a xpath expression. For more dynamic behavior use Recipient List or Dynamic Router EIP instead.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/toD.adoc[]
There is a new `.toD` / `<toD>` that allows to send a message to a dynamic
computed xref:latest@manual:ROOT:endpoint.adoc[Endpoint] using one or
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/topic-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/topic-eip.adoc
index efb5e38..ac9614c 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/topic-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/topic-eip.adoc
@@ -4,6 +4,7 @@
:description: Topic load balancer The topic load balancer sends to all destinations (rather like JMS Topics)
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/topic.adoc[]
Topic Load Balancer, with this policy you'll get a Topic behavior by sending to all destinations.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/transform-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/transform-eip.adoc
index da0e82b..86b2b2a 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/transform-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/transform-eip.adoc
@@ -4,6 +4,7 @@
:description: Transforms the message body based on an expression
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/transform.adoc[]
See below for details
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/validate-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/validate-eip.adoc
index cc923c0..ba2d70c 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/validate-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/validate-eip.adoc
@@ -4,6 +4,7 @@
:description: Validates a message based on an expression
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/validate.adoc[]
Validate uses an expression or predicates to validate the contents of a message.
It is useful for ensuring that messages are valid before attempting to process them.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/weighted-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/weighted-eip.adoc
index 90d08c1..55fe7e6 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/weighted-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/weighted-eip.adoc
@@ -4,6 +4,7 @@
:description: Weighted load balancer The weighted load balancing policy allows you to specify a processing load distribution ratio for each server with respect to others. In addition to the weight, endpoint selection is then further refined using random distribution based on weight.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/weighted.adoc[]
Weighted Load Balancer, with this policy in case of failures the exchange will be tried on the next endpoint.
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/when-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/when-eip.adoc
index b4cf993..d09c50e 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/when-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/when-eip.adoc
@@ -4,6 +4,7 @@
:description: Triggers a route when an expression evaluates to true
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/when.adoc[]
The When EIP is related to http://www.enterpriseintegrationpatterns.com/ContentBasedRouter.html[Content
Based Router] from the xref:enterprise-integration-patterns.adoc[EIP
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/wireTap-eip.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/wireTap-eip.adoc
index 81e75fa..75cb8dd 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/wireTap-eip.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/wireTap-eip.adoc
@@ -4,6 +4,7 @@
:description: Routes a copy of a message (or creates a new message) to a secondary destination while continue routing the original message.
:since:
:supportLevel: Stable
+include::{cq-version}@camel-quarkus:ROOT:partial$reference/eips/wireTap.adoc[]
http://www.enterpriseintegrationpatterns.com/WireTap.html[Wire Tap]
(from the xref:enterprise-integration-patterns.adoc[EIP patterns])
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/zipfile-dataformat.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/zipfile-dataformat.adoc
index c36c59a..be43fb5 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/zipfile-dataformat.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/zipfile-dataformat.adoc
@@ -18,7 +18,7 @@ This data format supports ZIP64, as long as Java 7 or later is being used].
== ZipFile Options
// dataformat options: START
-The Zip File dataformat supports 4 options, which are listed below.
+The Zip File dataformat supports 5 options, which are listed below.
@@ -28,6 +28,7 @@ The Zip File dataformat supports 4 options, which are listed below.
| usingIterator | false | Boolean | If the zip file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode.
| allowEmptyDirectory | false | Boolean | If the zip file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty
| preservePathElements | false | Boolean | If the file name contains path elements, setting this option to true, allows the path to be maintained in the zip file.
+| maxDecompressedSize | | Long | Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size.
| contentTypeHeader | false | Boolean | Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application/xml for data formats marshalling to XML, or application/json for data formats marshalling to JSON etc.
|===
// dataformat options: END
diff --git a/components/camel-tarfile/src/generated/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatConfigurer.java b/components/camel-tarfile/src/generated/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatConfigurer.java
index faaef7c..978c9af 100644
--- a/components/camel-tarfile/src/generated/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatConfigurer.java
+++ b/components/camel-tarfile/src/generated/java/org/apache/camel/dataformat/tarfile/TarFileDataFormatConfigurer.java
@@ -24,6 +24,8 @@ public class TarFileDataFormatConfigurer extends PropertyConfigurerSupport imple
case "allowEmptyDirectory": dataformat.setAllowEmptyDirectory(property(camelContext, boolean.class, value)); return true;
case "preservepathelements":
case "preservePathElements": dataformat.setPreservePathElements(property(camelContext, boolean.class, value)); return true;
+ case "maxdecompressedsize":
+ case "maxDecompressedSize": dataformat.setMaxDecompressedSize(property(camelContext, long.class, value)); return true;
default: return false;
}
}
diff --git a/components/camel-tarfile/src/generated/resources/org/apache/camel/dataformat/tarfile/tarfile.json b/components/camel-tarfile/src/generated/resources/org/apache/camel/dataformat/tarfile/tarfile.json
index e63ae5c..1af32df 100644
--- a/components/camel-tarfile/src/generated/resources/org/apache/camel/dataformat/tarfile/tarfile.json
+++ b/components/camel-tarfile/src/generated/resources/org/apache/camel/dataformat/tarfile/tarfile.json
@@ -19,6 +19,7 @@
"usingIterator": { "kind": "attribute", "displayName": "Using Iterator", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the tar file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode." },
"allowEmptyDirectory": { "kind": "attribute", "displayName": "Allow Empty Directory", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the tar file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty" },
"preservePathElements": { "kind": "attribute", "displayName": "Preserve Path Elements", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the file name contains path elements, setting this option to true, allows the path to be maintained in the tar file." },
+ "maxDecompressedSize": { "kind": "attribute", "displayName": "Max Decompressed Size", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "secret": false, "description": "Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size." },
"contentTypeHeader": { "kind": "attribute", "displayName": "Content Type Header", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application\/xml for data formats marshalling to XML, or application\/json for data formats marshalling to JS [...]
"id": { "kind": "attribute", "displayName": "Id", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "description": "The id of this node" }
}
diff --git a/components/camel-tarfile/src/main/docs/tarfile-dataformat.adoc b/components/camel-tarfile/src/main/docs/tarfile-dataformat.adoc
index 8b5e754..3c0bb20 100644
--- a/components/camel-tarfile/src/main/docs/tarfile-dataformat.adoc
+++ b/components/camel-tarfile/src/main/docs/tarfile-dataformat.adoc
@@ -21,7 +21,7 @@ aggregate multiple messages into a single Tar File.
// dataformat options: START
-The Tar File dataformat supports 4 options, which are listed below.
+The Tar File dataformat supports 5 options, which are listed below.
@@ -31,6 +31,7 @@ The Tar File dataformat supports 4 options, which are listed below.
| usingIterator | false | Boolean | If the tar file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode.
| allowEmptyDirectory | false | Boolean | If the tar file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty
| preservePathElements | false | Boolean | If the file name contains path elements, setting this option to true, allows the path to be maintained in the tar file.
+| maxDecompressedSize | | Long | Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size.
| contentTypeHeader | false | Boolean | Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application/xml for data formats marshalling to XML, or application/json for data formats marshalling to JSON etc.
|===
// dataformat options: END
diff --git a/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java b/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java
index 51d4847..ed3332e 100644
--- a/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java
+++ b/components/camel-tarfile/src/main/java/org/apache/camel/dataformat/tarfile/TarFileDataFormat.java
@@ -45,9 +45,14 @@ import static org.apache.camel.Exchange.FILE_NAME;
*/
@Dataformat("tarfile")
public class TarFileDataFormat extends ServiceSupport implements DataFormat, DataFormatName {
+ /**
+ * The default maximum decompressed size (in bytes), which corresponds to 1G.
+ */
+ private static final long DEFAULT_MAXIMUM_DECOMPRESSED_SIZE = 1073741824L;
private boolean usingIterator;
private boolean allowEmptyDirectory;
private boolean preservePathElements;
+ private long maxDecompressedSize = DEFAULT_MAXIMUM_DECOMPRESSED_SIZE;
@Override
public String getDataFormatName() {
@@ -108,7 +113,7 @@ public class TarFileDataFormat extends ServiceSupport implements DataFormat, Dat
TarArchiveEntry entry = tis.getNextTarEntry();
if (entry != null) {
exchange.getMessage().setHeader(FILE_NAME, entry.getName());
- IOHelper.copy(tis, osb);
+ IOHelper.copy(tis, osb, IOHelper.DEFAULT_BUFFER_SIZE, false, maxDecompressedSize);
} else {
throw new IllegalStateException("Unable to untar the file, it may be corrupted.");
}
@@ -175,6 +180,14 @@ public class TarFileDataFormat extends ServiceSupport implements DataFormat, Dat
this.preservePathElements = preservePathElements;
}
+ public long getMaxDecompressedSize() {
+ return maxDecompressedSize;
+ }
+
+ public void setMaxDecompressedSize(long maxDecompressedSize) {
+ this.maxDecompressedSize = maxDecompressedSize;
+ }
+
@Override
protected void doStart() throws Exception {
// noop
diff --git a/components/camel-zipfile/src/generated/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatConfigurer.java b/components/camel-zipfile/src/generated/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatConfigurer.java
index 72ea179..8f68fc1 100644
--- a/components/camel-zipfile/src/generated/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatConfigurer.java
+++ b/components/camel-zipfile/src/generated/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormatConfigurer.java
@@ -24,6 +24,8 @@ public class ZipFileDataFormatConfigurer extends PropertyConfigurerSupport imple
case "allowEmptyDirectory": dataformat.setAllowEmptyDirectory(property(camelContext, boolean.class, value)); return true;
case "preservepathelements":
case "preservePathElements": dataformat.setPreservePathElements(property(camelContext, boolean.class, value)); return true;
+ case "maxdecompressedsize":
+ case "maxDecompressedSize": dataformat.setMaxDecompressedSize(property(camelContext, long.class, value)); return true;
default: return false;
}
}
diff --git a/components/camel-zipfile/src/generated/resources/org/apache/camel/dataformat/zipfile/zipfile.json b/components/camel-zipfile/src/generated/resources/org/apache/camel/dataformat/zipfile/zipfile.json
index d885bc5..d03ec45 100644
--- a/components/camel-zipfile/src/generated/resources/org/apache/camel/dataformat/zipfile/zipfile.json
+++ b/components/camel-zipfile/src/generated/resources/org/apache/camel/dataformat/zipfile/zipfile.json
@@ -19,6 +19,7 @@
"usingIterator": { "kind": "attribute", "displayName": "Using Iterator", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the zip file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode." },
"allowEmptyDirectory": { "kind": "attribute", "displayName": "Allow Empty Directory", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the zip file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty" },
"preservePathElements": { "kind": "attribute", "displayName": "Preserve Path Elements", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the file name contains path elements, setting this option to true, allows the path to be maintained in the zip file." },
+ "maxDecompressedSize": { "kind": "attribute", "displayName": "Max Decompressed Size", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "secret": false, "description": "Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size." },
"contentTypeHeader": { "kind": "attribute", "displayName": "Content Type Header", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application\/xml for data formats marshalling to XML, or application\/json for data formats marshalling to JS [...]
"id": { "kind": "attribute", "displayName": "Id", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "description": "The id of this node" }
}
diff --git a/components/camel-zipfile/src/main/docs/zipfile-dataformat.adoc b/components/camel-zipfile/src/main/docs/zipfile-dataformat.adoc
index c36c59a..be43fb5 100644
--- a/components/camel-zipfile/src/main/docs/zipfile-dataformat.adoc
+++ b/components/camel-zipfile/src/main/docs/zipfile-dataformat.adoc
@@ -18,7 +18,7 @@ This data format supports ZIP64, as long as Java 7 or later is being used].
== ZipFile Options
// dataformat options: START
-The Zip File dataformat supports 4 options, which are listed below.
+The Zip File dataformat supports 5 options, which are listed below.
@@ -28,6 +28,7 @@ The Zip File dataformat supports 4 options, which are listed below.
| usingIterator | false | Boolean | If the zip file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode.
| allowEmptyDirectory | false | Boolean | If the zip file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty
| preservePathElements | false | Boolean | If the file name contains path elements, setting this option to true, allows the path to be maintained in the zip file.
+| maxDecompressedSize | | Long | Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size.
| contentTypeHeader | false | Boolean | Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application/xml for data formats marshalling to XML, or application/json for data formats marshalling to JSON etc.
|===
// dataformat options: END
diff --git a/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormat.java b/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormat.java
index 30ada21..e1295d6 100644
--- a/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormat.java
+++ b/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipFileDataFormat.java
@@ -42,9 +42,14 @@ import static org.apache.camel.Exchange.FILE_NAME;
*/
@Dataformat("zipfile")
public class ZipFileDataFormat extends ServiceSupport implements DataFormat, DataFormatName {
+ /**
+ * The default maximum decompressed size (in bytes), which corresponds to 1G.
+ */
+ private static final long DEFAULT_MAXIMUM_DECOMPRESSED_SIZE = 1073741824L;
private boolean usingIterator;
private boolean allowEmptyDirectory;
private boolean preservePathElements;
+ private long maxDecompressedSize = DEFAULT_MAXIMUM_DECOMPRESSED_SIZE;
@Override
public String getDataFormatName() {
@@ -96,7 +101,7 @@ public class ZipFileDataFormat extends ServiceSupport implements DataFormat, Dat
ZipEntry entry = zis.getNextEntry();
if (entry != null) {
exchange.getMessage().setHeader(FILE_NAME, entry.getName());
- IOHelper.copy(zis, osb);
+ IOHelper.copy(zis, osb, IOHelper.DEFAULT_BUFFER_SIZE, false, maxDecompressedSize);
} else {
throw new IllegalStateException("Unable to unzip the file, it may be corrupted.");
}
@@ -158,6 +163,14 @@ public class ZipFileDataFormat extends ServiceSupport implements DataFormat, Dat
this.preservePathElements = preservePathElements;
}
+ public long getMaxDecompressedSize() {
+ return maxDecompressedSize;
+ }
+
+ public void setMaxDecompressedSize(long maxDecompressedSize) {
+ this.maxDecompressedSize = maxDecompressedSize;
+ }
+
@Override
protected void doStart() throws Exception {
// noop
diff --git a/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/tarfile.json b/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/tarfile.json
index c0a07c34..3456e6e 100644
--- a/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/tarfile.json
+++ b/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/tarfile.json
@@ -15,6 +15,7 @@
"usingIterator": { "kind": "attribute", "displayName": "Using Iterator", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the tar file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode." },
"allowEmptyDirectory": { "kind": "attribute", "displayName": "Allow Empty Directory", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the tar file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty" },
"preservePathElements": { "kind": "attribute", "displayName": "Preserve Path Elements", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the file name contains path elements, setting this option to true, allows the path to be maintained in the tar file." },
+ "maxDecompressedSize": { "kind": "attribute", "displayName": "Max Decompressed Size", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "secret": false, "description": "Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size." },
"contentTypeHeader": { "kind": "attribute", "displayName": "Content Type Header", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application\/xml for data formats marshalling to XML, or application\/json for data formats marshalling to JS [...]
"id": { "kind": "attribute", "displayName": "Id", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "description": "The id of this node" }
}
diff --git a/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/zipfile.json b/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/zipfile.json
index 279beb7..14fcd27 100644
--- a/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/zipfile.json
+++ b/core/camel-core-engine/src/generated/resources/org/apache/camel/model/dataformat/zipfile.json
@@ -15,6 +15,7 @@
"usingIterator": { "kind": "attribute", "displayName": "Using Iterator", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the zip file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode." },
"allowEmptyDirectory": { "kind": "attribute", "displayName": "Allow Empty Directory", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the zip file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty" },
"preservePathElements": { "kind": "attribute", "displayName": "Preserve Path Elements", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "If the file name contains path elements, setting this option to true, allows the path to be maintained in the zip file." },
+ "maxDecompressedSize": { "kind": "attribute", "displayName": "Max Decompressed Size", "required": false, "type": "integer", "javaType": "java.lang.Long", "deprecated": false, "secret": false, "description": "Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size." },
"contentTypeHeader": { "kind": "attribute", "displayName": "Content Type Header", "required": false, "type": "boolean", "javaType": "java.lang.Boolean", "deprecated": false, "secret": false, "defaultValue": false, "description": "Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application\/xml for data formats marshalling to XML, or application\/json for data formats marshalling to JS [...]
"id": { "kind": "attribute", "displayName": "Id", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "secret": false, "description": "The id of this node" }
}
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/TarFileDataFormat.java b/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/TarFileDataFormat.java
index 5d06cd8..35c53b2 100644
--- a/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/TarFileDataFormat.java
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/TarFileDataFormat.java
@@ -40,6 +40,9 @@ public class TarFileDataFormat extends DataFormatDefinition {
@XmlAttribute
@Metadata(javaType = "java.lang.Boolean")
private String preservePathElements;
+ @XmlAttribute
+ @Metadata(javaType = "java.lang.Long")
+ private String maxDecompressedSize;
public TarFileDataFormat() {
super("tarfile");
@@ -57,6 +60,10 @@ public class TarFileDataFormat extends DataFormatDefinition {
return preservePathElements;
}
+ public String getMaxDecompressedSize() {
+ return maxDecompressedSize;
+ }
+
/**
* If the tar file has more then one entry, the setting this option to true, allows to work with the splitter EIP,
* to split the data using an iterator in a streaming mode.
@@ -80,4 +87,16 @@ public class TarFileDataFormat extends DataFormatDefinition {
public void setPreservePathElements(String preservePathElements) {
this.preservePathElements = preservePathElements;
}
+
+ /**
+ * Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1
+ * gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable
+ * setting a maximum decompressed size.
+ *
+ * @param maxDecompressedSize
+ */
+ public void setMaxDecompressedSize(String maxDecompressedSize) {
+ this.maxDecompressedSize = maxDecompressedSize;
+ }
+
}
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/ZipFileDataFormat.java b/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/ZipFileDataFormat.java
index 6488d3d..4b07d01 100644
--- a/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/ZipFileDataFormat.java
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/model/dataformat/ZipFileDataFormat.java
@@ -40,6 +40,9 @@ public class ZipFileDataFormat extends DataFormatDefinition {
@XmlAttribute
@Metadata(javaType = "java.lang.Boolean")
private String preservePathElements;
+ @XmlAttribute
+ @Metadata(javaType = "java.lang.Long")
+ private String maxDecompressedSize;
public ZipFileDataFormat() {
super("zipfile");
@@ -57,6 +60,10 @@ public class ZipFileDataFormat extends DataFormatDefinition {
return preservePathElements;
}
+ public String getMaxDecompressedSize() {
+ return maxDecompressedSize;
+ }
+
/**
* If the zip file has more then one entry, the setting this option to true, allows to work with the splitter EIP,
* to split the data using an iterator in a streaming mode.
@@ -81,4 +88,14 @@ public class ZipFileDataFormat extends DataFormatDefinition {
this.preservePathElements = preservePathElements;
}
+ /**
+ * Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1
+ * gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable
+ * setting a maximum decompressed size.
+ *
+ * @param maxDecompressedSize
+ */
+ public void setMaxDecompressedSize(String maxDecompressedSize) {
+ this.maxDecompressedSize = maxDecompressedSize;
+ }
}
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/TarFileDataFormatReifier.java b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/TarFileDataFormatReifier.java
index 3245645..889db99 100644
--- a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/TarFileDataFormatReifier.java
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/TarFileDataFormatReifier.java
@@ -32,6 +32,7 @@ public class TarFileDataFormatReifier extends DataFormatReifier<TarFileDataForma
protected void prepareDataFormatConfig(Map<String, Object> properties) {
properties.put("usingIterator", definition.getUsingIterator());
properties.put("preservePathElements", definition.getPreservePathElements());
+ properties.put("maxDecompressedSize", definition.getMaxDecompressedSize());
}
}
diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/ZipFileDataFormatReifier.java b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/ZipFileDataFormatReifier.java
index a67c61f..2c7c0db 100644
--- a/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/ZipFileDataFormatReifier.java
+++ b/core/camel-core-engine/src/main/java/org/apache/camel/reifier/dataformat/ZipFileDataFormatReifier.java
@@ -33,6 +33,7 @@ public class ZipFileDataFormatReifier extends DataFormatReifier<ZipFileDataForma
properties.put("usingIterator", definition.getUsingIterator());
properties.put("allowEmptyDirectory", definition.getAllowEmptyDirectory());
properties.put("preservePathElements", definition.getPreservePathElements());
+ properties.put("maxDecompressedSize", definition.getMaxDecompressedSize());
}
}
diff --git a/core/camel-util/src/main/java/org/apache/camel/util/IOHelper.java b/core/camel-util/src/main/java/org/apache/camel/util/IOHelper.java
index 7318961..63986c3 100644
--- a/core/camel-util/src/main/java/org/apache/camel/util/IOHelper.java
+++ b/core/camel-util/src/main/java/org/apache/camel/util/IOHelper.java
@@ -149,6 +149,12 @@ public final class IOHelper {
public static int copy(final InputStream input, final OutputStream output, int bufferSize, boolean flushOnEachWrite)
throws IOException {
+ return copy(input, output, bufferSize, flushOnEachWrite, -1);
+ }
+
+ public static int copy(final InputStream input, final OutputStream output, int bufferSize, boolean flushOnEachWrite,
+ long maxSize) throws IOException {
+
if (input instanceof ByteArrayInputStream) {
// optimized for byte array as we only need the max size it can be
input.mark(0);
@@ -191,6 +197,9 @@ public final class IOHelper {
output.flush();
}
total += n;
+ if (maxSize > 0 && total > maxSize) {
+ throw new IOException("The InputStream entry being copied exceeds the maximum allowed size");
+ }
n = input.read(buffer);
}
}
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 354617f..1214a17 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
@@ -2120,6 +2120,7 @@ public class ModelParser extends BaseParser {
return doParse(new TarFileDataFormat(), (def, key, val) -> {
switch (key) {
case "allowEmptyDirectory": def.setAllowEmptyDirectory(val); break;
+ case "maxDecompressedSize": def.setMaxDecompressedSize(val); break;
case "preservePathElements": def.setPreservePathElements(val); break;
case "usingIterator": def.setUsingIterator(val); break;
default: return dataFormatDefinitionAttributeHandler().accept(def, key, val);
@@ -2317,6 +2318,7 @@ public class ModelParser extends BaseParser {
return doParse(new ZipFileDataFormat(), (def, key, val) -> {
switch (key) {
case "allowEmptyDirectory": def.setAllowEmptyDirectory(val); break;
+ case "maxDecompressedSize": def.setMaxDecompressedSize(val); break;
case "preservePathElements": def.setPreservePathElements(val); break;
case "usingIterator": def.setUsingIterator(val); break;
default: return dataFormatDefinitionAttributeHandler().accept(def, key, val);
diff --git a/docs/components/modules/dataformats/pages/tarfile-dataformat.adoc b/docs/components/modules/dataformats/pages/tarfile-dataformat.adoc
index e3ef5af..dc94e27 100644
--- a/docs/components/modules/dataformats/pages/tarfile-dataformat.adoc
+++ b/docs/components/modules/dataformats/pages/tarfile-dataformat.adoc
@@ -23,7 +23,7 @@ aggregate multiple messages into a single Tar File.
// dataformat options: START
-The Tar File dataformat supports 4 options, which are listed below.
+The Tar File dataformat supports 5 options, which are listed below.
@@ -33,6 +33,7 @@ The Tar File dataformat supports 4 options, which are listed below.
| usingIterator | false | Boolean | If the tar file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode.
| allowEmptyDirectory | false | Boolean | If the tar file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty
| preservePathElements | false | Boolean | If the file name contains path elements, setting this option to true, allows the path to be maintained in the tar file.
+| maxDecompressedSize | | Long | Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size.
| contentTypeHeader | false | Boolean | Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application/xml for data formats marshalling to XML, or application/json for data formats marshalling to JSON etc.
|===
// dataformat options: END
diff --git a/docs/components/modules/dataformats/pages/zipfile-dataformat.adoc b/docs/components/modules/dataformats/pages/zipfile-dataformat.adoc
index 6f2d2f5..fd71f4b 100644
--- a/docs/components/modules/dataformats/pages/zipfile-dataformat.adoc
+++ b/docs/components/modules/dataformats/pages/zipfile-dataformat.adoc
@@ -20,7 +20,7 @@ This data format supports ZIP64, as long as Java 7 or later is being used].
== ZipFile Options
// dataformat options: START
-The Zip File dataformat supports 4 options, which are listed below.
+The Zip File dataformat supports 5 options, which are listed below.
@@ -30,6 +30,7 @@ The Zip File dataformat supports 4 options, which are listed below.
| usingIterator | false | Boolean | If the zip file has more then one entry, the setting this option to true, allows to work with the splitter EIP, to split the data using an iterator in a streaming mode.
| allowEmptyDirectory | false | Boolean | If the zip file has more then one entry, setting this option to true, allows to get the iterator even if the directory is empty
| preservePathElements | false | Boolean | If the file name contains path elements, setting this option to true, allows the path to be maintained in the zip file.
+| maxDecompressedSize | | Long | Set the maximum decompressed size of a tar file (in bytes). The default value if not specified corresponds to 1 gigabyte. An IOException will be thrown if the decompressed size exceeds this amount. Set to -1 to disable setting a maximum decompressed size.
| contentTypeHeader | false | Boolean | Whether the data format should set the Content-Type header with the type from the data format if the data format is capable of doing so. For example application/xml for data formats marshalling to XML, or application/json for data formats marshalling to JSON etc.
|===
// dataformat options: END