This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.x by this push:
new 98799b38f39 Regen for commit 7f38011b0fb3ca460e7f6a78d0005950e8b40347
(#10462)
98799b38f39 is described below
commit 98799b38f39a7d711391db4411c8fc5734c2e46a
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Jun 21 13:24:23 2023 +0200
Regen for commit 7f38011b0fb3ca460e7f6a78d0005950e8b40347 (#10462)
Signed-off-by: GitHub <nore...@github.com>
Co-authored-by: davsclaus <davscl...@users.noreply.github.com>
---
.../org/apache/camel/catalog/models/multicast.json | 3 +-
.../apache/camel/catalog/models/recipientList.json | 3 +-
.../org/apache/camel/catalog/models/split.json | 3 +-
.../apache/camel/catalog/schemas/camel-spring.xsd | 54 ++++++++++++++++++++--
4 files changed, 57 insertions(+), 6 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/multicast.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/multicast.json
index 1d1113310f9..4d58a81816f 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/multicast.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/multicast.json
@@ -16,7 +16,8 @@
"aggregationStrategyMethodName": { "kind": "attribute", "displayName":
"Aggregation Strategy Method Name", "label": "advanced", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "This option can be used to
explicit declare the method name to use, when using POJOs as the
AggregationStrategy." },
"aggregationStrategyMethodAllowNull": { "kind": "attribute",
"displayName": "Aggregation Strategy Method Allow Null", "label": "advanced",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If this option is false then the aggregate method is not
used if there was no data to enrich. If this option is true then null values is
used as the oldExchange (when no data to enr [...]
"parallelAggregate": { "kind": "attribute", "displayName": "Parallel
Aggregate", "label": "advanced", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled then the
aggregate method on AggregationStrategy can be called concurrently. Notice that
this would require the implementation of AggregationStrategy to be implemented
as thread-safe. By default this is fals [...]
- "parallelProcessing": { "kind": "attribute", "displayName": "Parallel
Processing", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If enabled then sending messages to the
multicasts occurs concurrently. Note the caller thread will still wait until
all messages has been fully processed, before it continues. Its only the
sending and processing the replies from the mul [...]
+ "parallelProcessing": { "kind": "attribute", "displayName": "Parallel
Processing", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If enabled then sending messages to the
multicasts occurs concurrently. Note the caller thread will still wait until
all messages has been fully processed, before it continues. Its only the
sending and processing the replies from the mul [...]
+ "synchronous": { "kind": "attribute", "displayName": "Synchronous",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "Sets whether synchronous processing should be strictly
used. When enabled then the same thread is used to continue routing after the
multicast is complete, even if parallel processing is enabled." },
"streaming": { "kind": "attribute", "displayName": "Streaming",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If enabled then Camel will process replies out-of-order,
eg in the order they come back. If disabled, Camel will process replies in the
same order as defined by the multicast." },
"stopOnException": { "kind": "attribute", "displayName": "Stop On
Exception", "label": "advanced", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Will now stop further
processing if an exception or failure occurred during processing of an
org.apache.camel.Exchange and the caused exception will be thrown. Will also
stop if processing the exchange failed (has a fault [...]
"timeout": { "kind": "attribute", "displayName": "Timeout", "label":
"advanced", "required": false, "type": "duration", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0", "description": "Sets a total timeout specified in millis,
when using parallel processing. If the Multicast hasn't been able to send and
process all replies within the given timeframe, then the timeout triggers and
the Multicast breaks out and continues. Not [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/recipientList.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/recipientList.json
index 13b1135ecb2..3580661323a 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/recipientList.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/recipientList.json
@@ -18,7 +18,8 @@
"aggregationStrategyMethodName": { "kind": "attribute", "displayName":
"Aggregation Strategy Method Name", "label": "advanced", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "This option can be used to
explicit declare the method name to use, when using POJOs as the
AggregationStrategy." },
"aggregationStrategyMethodAllowNull": { "kind": "attribute",
"displayName": "Aggregation Strategy Method Allow Null", "label": "advanced",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If this option is false then the aggregate method is not
used if there was no data to enrich. If this option is true then null values is
used as the oldExchange (when no data to enr [...]
"parallelAggregate": { "kind": "attribute", "displayName": "Parallel
Aggregate", "label": "advanced", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled then the
aggregate method on AggregationStrategy can be called concurrently. Notice that
this would require the implementation of AggregationStrategy to be implemented
as thread-safe. By default this is fals [...]
- "parallelProcessing": { "kind": "attribute", "displayName": "Parallel
Processing", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If enabled then sending messages to the
recipients occurs concurrently. Note the caller thread will still wait until
all messages has been fully processed, before it continues. Its only the
sending and processing the replies from the rec [...]
+ "parallelProcessing": { "kind": "attribute", "displayName": "Parallel
Processing", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If enabled then sending messages to the
recipients occurs concurrently. Note the caller thread will still wait until
all messages has been fully processed, before it continues. Its only the
sending and processing the replies from the rec [...]
+ "synchronous": { "kind": "attribute", "displayName": "Synchronous",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "Sets whether synchronous processing should be strictly
used. When enabled then the same thread is used to continue routing after the
recipient list is complete, even if parallel processing is enabled." },
"timeout": { "kind": "attribute", "displayName": "Timeout", "required":
false, "type": "duration", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "0", "description": "Sets
a total timeout specified in millis, when using parallel processing. If the
Recipient List hasn't been able to send and process all replies within the
given timeframe, then the timeout triggers and the Recipient List breaks out
and continues. Notice if you [...]
"executorService": { "kind": "attribute", "displayName": "Executor
Service", "label": "advanced", "required": false, "type": "object", "javaType":
"java.util.concurrent.ExecutorService", "deprecated": false, "autowired":
false, "secret": false, "description": "To use a custom Thread Pool to be used
for parallel processing. Notice if you set this option, then parallel
processing is automatic implied, and you do not have to enable that option as
well." },
"stopOnException": { "kind": "attribute", "displayName": "Stop On
Exception", "label": "advanced", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Will now stop further
processing if an exception or failure occurred during processing of an
org.apache.camel.Exchange and the caused exception will be thrown. Will also
stop if processing the exchange failed (has a fault [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/split.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/split.json
index 5087b2b7ed2..001943dc58d 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/split.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/models/split.json
@@ -18,7 +18,8 @@
"aggregationStrategyMethodName": { "kind": "attribute", "displayName":
"Aggregation Strategy Method Name", "label": "advanced", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "description": "This option can be used to
explicit declare the method name to use, when using POJOs as the
AggregationStrategy." },
"aggregationStrategyMethodAllowNull": { "kind": "attribute",
"displayName": "Aggregation Strategy Method Allow Null", "label": "advanced",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "If this option is false then the aggregate method is not
used if there was no data to enrich. If this option is true then null values is
used as the oldExchange (when no data to enr [...]
"parallelAggregate": { "kind": "attribute", "displayName": "Parallel
Aggregate", "label": "advanced", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If enabled then the
aggregate method on AggregationStrategy can be called concurrently. Notice that
this would require the implementation of AggregationStrategy to be implemented
as thread-safe. By default this is fals [...]
- "parallelProcessing": { "kind": "attribute", "displayName": "Parallel
Processing", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If enabled then processing each split
messages occurs concurrently. Note the caller thread will still wait until all
messages has been fully processed, before it continues. It's only processing
the sub messages from the splitter which ha [...]
+ "parallelProcessing": { "kind": "attribute", "displayName": "Parallel
Processing", "required": false, "type": "boolean", "javaType":
"java.lang.Boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "If enabled then processing each split
messages occurs concurrently. Note the caller thread will still wait until all
messages has been fully processed, before it continues. It's only processing
the sub messages from the splitter which ha [...]
+ "synchronous": { "kind": "attribute", "displayName": "Synchronous",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "Sets whether synchronous processing should be strictly
used. When enabled then the same thread is used to continue routing after the
split is complete, even if parallel processing is enabled." },
"streaming": { "kind": "attribute", "displayName": "Streaming",
"required": false, "type": "boolean", "javaType": "java.lang.Boolean",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
false, "description": "When in streaming mode, then the splitter splits the
original message on-demand, and each split message is processed one by one.
This reduces memory usage as the splitter do not split all the messages first,
but then we do not know the total size, and ther [...]
"stopOnException": { "kind": "attribute", "displayName": "Stop On
Exception", "label": "advanced", "required": false, "type": "boolean",
"javaType": "java.lang.Boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Will now stop further
processing if an exception or failure occurred during processing of an
org.apache.camel.Exchange and the caused exception will be thrown. Will also
stop if processing the exchange failed (has a fault [...]
"timeout": { "kind": "attribute", "displayName": "Timeout", "label":
"advanced", "required": false, "type": "duration", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "0", "description": "Sets a total timeout specified in millis,
when using parallel processing. If the Splitter hasn't been able to split and
process all the sub messages within the given timeframe, then the timeout
triggers and the Splitter breaks out and contin [...]
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
index 758fda6c398..eef5f6cdb6f 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd
@@ -13578,7 +13578,23 @@ AggregationStrategy is implemented as thread-safe.
Default value: false
If enabled then sending messages to the multicasts occurs concurrently. Note
the
caller thread will still wait until all messages has been fully processed,
before it continues. Its only the sending and processing the replies from the
-multicasts which happens concurrently. Default value: false
+multicasts which happens concurrently. When parallel processing is enabled,
then
+the Camel routing engin will continue processing using last used thread from
the
+parallel thread pool. However, if you want to use the original thread that
+called the multicast, then make sure to enable the synchronous option as well.
+Default value: false
+ ]]>
+ </xs:documentation>
+ </xs:annotation>
+ </xs:attribute>
+
+ <xs:attribute name="synchronous" type="xs:string">
+ <xs:annotation>
+ <xs:documentation xml:lang="en">
+ <![CDATA[
+Sets whether synchronous processing should be strictly used. When enabled then
+the same thread is used to continue routing after the multicast is complete,
+even if parallel processing is enabled. Default value: false
]]>
</xs:documentation>
</xs:annotation>
@@ -15232,7 +15248,23 @@ AggregationStrategy is implemented as thread-safe.
Default value: false
If enabled then sending messages to the recipients occurs concurrently. Note
the
caller thread will still wait until all messages has been fully processed,
before it continues. Its only the sending and processing the replies from the
-recipients which happens concurrently. Default value: false
+recipients which happens concurrently. When parallel processing is enabled,
then
+the Camel routing engin will continue processing using last used thread from
the
+parallel thread pool. However, if you want to use the original thread that
+called the recipient list, then make sure to enable the synchronous option as
+well. Default value: false
+ ]]>
+ </xs:documentation>
+ </xs:annotation>
+ </xs:attribute>
+
+ <xs:attribute name="synchronous" type="xs:string">
+ <xs:annotation>
+ <xs:documentation xml:lang="en">
+ <![CDATA[
+Sets whether synchronous processing should be strictly used. When enabled then
+the same thread is used to continue routing after the recipient list is
+complete, even if parallel processing is enabled. Default value: false
]]>
</xs:documentation>
</xs:annotation>
@@ -17562,7 +17594,23 @@ AggregationStrategy is implemented as thread-safe.
Default value: false
If enabled then processing each split messages occurs concurrently. Note the
caller thread will still wait until all messages has been fully processed,
before it continues. It's only processing the sub messages from the splitter
-which happens concurrently. Default value: false
+which happens concurrently. When parallel processing is enabled, then the Camel
+routing engin will continue processing using last used thread from the parallel
+thread pool. However, if you want to use the original thread that called the
+splitter, then make sure to enable the synchronous option as well. Default
+value: false
+ ]]>
+ </xs:documentation>
+ </xs:annotation>
+ </xs:attribute>
+
+ <xs:attribute name="synchronous" type="xs:string">
+ <xs:annotation>
+ <xs:documentation xml:lang="en">
+ <![CDATA[
+Sets whether synchronous processing should be strictly used. When enabled then
+the same thread is used to continue routing after the split is complete, even
if
+parallel processing is enabled. Default value: false
]]>
</xs:documentation>
</xs:annotation>
