You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2023/11/10 18:28:15 UTC
(camel) branch main updated (d7569d23e26 -> f59c6384d85)
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
from d7569d23e26 Fix rat check
new 566896bcd5b CAMEL-20102: camel-vertx-http - Make configuring http method tooling friendly
new f59c6384d85 Regen
The 2 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.
Summary of changes:
.../camel/catalog/components/vertx-http.json | 2 +-
.../camel/component/vertx/http/vertx-http.json | 2 +-
.../vertx/http/VertxHttpConfiguration.java | 10 +-
.../dsl/DynamicRouterEndpointBuilderFactory.java | 357 ++++++++++++++++++++-
.../dsl/PlatformHttpEndpointBuilderFactory.java | 6 +-
5 files changed, 370 insertions(+), 7 deletions(-)
(camel) 01/02: CAMEL-20102: camel-vertx-http - Make configuring http method tooling friendly
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 566896bcd5bf2df339f464e2d171339b53868f85
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Nov 10 19:27:52 2023 +0100
CAMEL-20102: camel-vertx-http - Make configuring http method tooling friendly
---
.../org/apache/camel/catalog/components/vertx-http.json | 2 +-
.../org/apache/camel/component/vertx/http/vertx-http.json | 2 +-
.../camel/component/vertx/http/VertxHttpConfiguration.java | 10 +++++++++-
3 files changed, 11 insertions(+), 3 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-http.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-http.json
index 6a2ce300a1f..6d4e8123895 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-http.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/vertx-http.json
@@ -57,7 +57,7 @@
"connectTimeout": { "index": 1, "kind": "parameter", "displayName": "Connect Timeout", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 60000, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "The amount of time in milliseconds until a connection is established. A timeout [...]
"cookieStore": { "index": 2, "kind": "parameter", "displayName": "Cookie Store", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "io.vertx.ext.web.client.spi.CookieStore", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "InMemoryCookieStore", "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "A custom CookieStore to use when se [...]
"headerFilterStrategy": { "index": 3, "kind": "parameter", "displayName": "Header Filter Strategy", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.spi.HeaderFilterStrategy", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "VertxHttpHeaderFilterStrategy", "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "A cu [...]
- "httpMethod": { "index": 4, "kind": "parameter", "displayName": "Http Method", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "io.vertx.core.http.HttpMethod", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "The HTTP method to use. The HttpMethod header cannot override this option if set" },
+ "httpMethod": { "index": 4, "kind": "parameter", "displayName": "Http Method", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "io.vertx.core.http.HttpMethod", "enum": [ "OPTIONS", "GET", "HEAD", "POST", "PUT", "DELETE", "TRACE", "CONNECT", "PATCH", "PROPFIND", "PROPPATCH", "MKCOL", "COPY", "MOVE", "LOCK", "UNLOCK", "MKCALENDAR", "VERSION_CONTROL", "REPORT", "CHECKIN", "CHECKOUT", "UNCHECKOUT", "MKWORKSPACE", "UPDATE", "LABEL", "MERGE", "BAS [...]
"okStatusCodeRange": { "index": 5, "kind": "parameter", "displayName": "Ok Status Code Range", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200-299", "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "The status codes which are considered a success response [...]
"responsePayloadAsByteArray": { "index": 6, "kind": "parameter", "displayName": "Response Payload As Byte Array", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "Whether the response body should be byte or as io. [...]
"sessionManagement": { "index": 7, "kind": "parameter", "displayName": "Session Management", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "Enables session management via WebClientSession. By default the client [...]
diff --git a/components/camel-vertx/camel-vertx-http/src/generated/resources/org/apache/camel/component/vertx/http/vertx-http.json b/components/camel-vertx/camel-vertx-http/src/generated/resources/org/apache/camel/component/vertx/http/vertx-http.json
index 6a2ce300a1f..6d4e8123895 100644
--- a/components/camel-vertx/camel-vertx-http/src/generated/resources/org/apache/camel/component/vertx/http/vertx-http.json
+++ b/components/camel-vertx/camel-vertx-http/src/generated/resources/org/apache/camel/component/vertx/http/vertx-http.json
@@ -57,7 +57,7 @@
"connectTimeout": { "index": 1, "kind": "parameter", "displayName": "Connect Timeout", "group": "producer", "label": "producer", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 60000, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "The amount of time in milliseconds until a connection is established. A timeout [...]
"cookieStore": { "index": 2, "kind": "parameter", "displayName": "Cookie Store", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "io.vertx.ext.web.client.spi.CookieStore", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "InMemoryCookieStore", "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "A custom CookieStore to use when se [...]
"headerFilterStrategy": { "index": 3, "kind": "parameter", "displayName": "Header Filter Strategy", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.spi.HeaderFilterStrategy", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "VertxHttpHeaderFilterStrategy", "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "A cu [...]
- "httpMethod": { "index": 4, "kind": "parameter", "displayName": "Http Method", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "io.vertx.core.http.HttpMethod", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "The HTTP method to use. The HttpMethod header cannot override this option if set" },
+ "httpMethod": { "index": 4, "kind": "parameter", "displayName": "Http Method", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "io.vertx.core.http.HttpMethod", "enum": [ "OPTIONS", "GET", "HEAD", "POST", "PUT", "DELETE", "TRACE", "CONNECT", "PATCH", "PROPFIND", "PROPPATCH", "MKCOL", "COPY", "MOVE", "LOCK", "UNLOCK", "MKCALENDAR", "VERSION_CONTROL", "REPORT", "CHECKIN", "CHECKOUT", "UNCHECKOUT", "MKWORKSPACE", "UPDATE", "LABEL", "MERGE", "BAS [...]
"okStatusCodeRange": { "index": 5, "kind": "parameter", "displayName": "Ok Status Code Range", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "200-299", "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "The status codes which are considered a success response [...]
"responsePayloadAsByteArray": { "index": 6, "kind": "parameter", "displayName": "Response Payload As Byte Array", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "Whether the response body should be byte or as io. [...]
"sessionManagement": { "index": 7, "kind": "parameter", "displayName": "Session Management", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.vertx.http.VertxHttpConfiguration", "configurationField": "configuration", "description": "Enables session management via WebClientSession. By default the client [...]
diff --git a/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpConfiguration.java b/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpConfiguration.java
index 36be1f8a0b8..7046640005c 100644
--- a/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpConfiguration.java
+++ b/components/camel-vertx/camel-vertx-http/src/main/java/org/apache/camel/component/vertx/http/VertxHttpConfiguration.java
@@ -36,7 +36,8 @@ public class VertxHttpConfiguration {
@UriPath(name = "httpUri")
@Metadata(required = true)
private URI httpUri;
- @UriParam(label = "producer")
+ @UriParam(label = "producer",
+ enums = "OPTIONS,GET,HEAD,POST,PUT,DELETE,TRACE,CONNECT,PATCH,PROPFIND,PROPPATCH,MKCOL,COPY,MOVE,LOCK,UNLOCK,MKCALENDAR,VERSION_CONTROL,REPORT,CHECKIN,CHECKOUT,UNCHECKOUT,MKWORKSPACE,UPDATE,LABEL,MERGE,BASELINE_CONTROL,MKACTIVITY,ORDERPATCH,ACL,SEARCH")
private HttpMethod httpMethod;
@UriParam(label = "producer", defaultValue = "-1")
private long timeout = -1;
@@ -99,6 +100,13 @@ public class VertxHttpConfiguration {
this.httpMethod = httpMethod;
}
+ /**
+ * The HTTP method to use. The HttpMethod header cannot override this option if set
+ */
+ public void setHttpMethod(String httpMethod) {
+ this.httpMethod = HttpMethod.valueOf(httpMethod);
+ }
+
public HttpMethod getHttpMethod() {
return httpMethod;
}
(camel) 02/02: Regen
Posted by da...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit f59c6384d85982c41168d4a7dff642e8c98e2ba9
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Fri Nov 10 19:28:00 2023 +0100
Regen
---
.../dsl/DynamicRouterEndpointBuilderFactory.java | 357 ++++++++++++++++++++-
.../dsl/PlatformHttpEndpointBuilderFactory.java | 6 +-
2 files changed, 359 insertions(+), 4 deletions(-)
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java
index 3e055636707..93ea2dca53d 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DynamicRouterEndpointBuilderFactory.java
@@ -44,6 +44,188 @@ public interface DynamicRouterEndpointBuilderFactory {
default AdvancedDynamicRouterEndpointBuilder advanced() {
return (AdvancedDynamicRouterEndpointBuilder) this;
}
+ /**
+ * Refers to an AggregationStrategy to be used to assemble the replies
+ * from the multicasts, into a single outgoing message from the
+ * Multicast. By default, Camel will use the last reply as the outgoing
+ * message. You can also use a POJO as the AggregationStrategy.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param aggregationStrategy the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder aggregationStrategy(
+ String aggregationStrategy) {
+ doSetProperty("aggregationStrategy", aggregationStrategy);
+ return this;
+ }
+ /**
+ * Refers to a custom Thread Pool to be used for parallel processing.
+ * Notice that, if you set this option, then parallel processing is
+ * automatically implied, and you do not have to enable that option in
+ * addition to this one.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param executorService the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder executorService(
+ String executorService) {
+ doSetProperty("executorService", executorService);
+ return this;
+ }
+ /**
+ * Ignore the invalid endpoint exception when attempting to create a
+ * producer with an invalid endpoint.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param ignoreInvalidEndpoints the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder ignoreInvalidEndpoints(
+ boolean ignoreInvalidEndpoints) {
+ doSetProperty("ignoreInvalidEndpoints", ignoreInvalidEndpoints);
+ return this;
+ }
+ /**
+ * Ignore the invalid endpoint exception when attempting to create a
+ * producer with an invalid endpoint.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param ignoreInvalidEndpoints the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder ignoreInvalidEndpoints(
+ String ignoreInvalidEndpoints) {
+ doSetProperty("ignoreInvalidEndpoints", ignoreInvalidEndpoints);
+ return this;
+ }
+ /**
+ * Uses the Processor when preparing the org.apache.camel.Exchange to be
+ * sent. This can be used to deep-clone messages that should be sent, or
+ * to provide any custom logic that is needed before the exchange is
+ * sent.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param onPrepare the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder onPrepare(String onPrepare) {
+ doSetProperty("onPrepare", onPrepare);
+ return this;
+ }
+ /**
+ * If enabled then the aggregate method on AggregationStrategy can be
+ * called concurrently. Notice that this would require the
+ * implementation of AggregationStrategy to be implemented as
+ * thread-safe. By default, this is false, meaning that Camel
+ * synchronizes the call to the aggregate method. Though, in some
+ * use-cases, this can be used to archive higher performance when the
+ * AggregationStrategy is implemented as thread-safe.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param parallelAggregate the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder parallelAggregate(
+ boolean parallelAggregate) {
+ doSetProperty("parallelAggregate", parallelAggregate);
+ return this;
+ }
+ /**
+ * If enabled then the aggregate method on AggregationStrategy can be
+ * called concurrently. Notice that this would require the
+ * implementation of AggregationStrategy to be implemented as
+ * thread-safe. By default, this is false, meaning that Camel
+ * synchronizes the call to the aggregate method. Though, in some
+ * use-cases, this can be used to archive higher performance when the
+ * AggregationStrategy is implemented as thread-safe.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param parallelAggregate the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder parallelAggregate(
+ String parallelAggregate) {
+ doSetProperty("parallelAggregate", parallelAggregate);
+ return this;
+ }
+ /**
+ * If enabled, then sending via multicast occurs concurrently. Note that
+ * the caller thread will still wait until all messages have been fully
+ * processed before it continues. It is only the sending and processing
+ * of the replies from the multicast recipients that happens
+ * concurrently. When parallel processing is enabled, then the Camel
+ * routing engine will continue processing using the 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.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param parallelProcessing the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder parallelProcessing(
+ boolean parallelProcessing) {
+ doSetProperty("parallelProcessing", parallelProcessing);
+ return this;
+ }
+ /**
+ * If enabled, then sending via multicast occurs concurrently. Note that
+ * the caller thread will still wait until all messages have been fully
+ * processed before it continues. It is only the sending and processing
+ * of the replies from the multicast recipients that happens
+ * concurrently. When parallel processing is enabled, then the Camel
+ * routing engine will continue processing using the 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.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param parallelProcessing the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder parallelProcessing(
+ String parallelProcessing) {
+ doSetProperty("parallelProcessing", parallelProcessing);
+ return this;
+ }
/**
* Recipient mode: firstMatch or allMatch.
*
@@ -60,7 +242,130 @@ public interface DynamicRouterEndpointBuilderFactory {
return this;
}
/**
- * Flag to ensure synchronous processing.
+ * Shares the org.apache.camel.spi.UnitOfWork with the parent and each
+ * of the sub messages. Multicast will, by default, not share a unit of
+ * work between the parent exchange and each multicasted exchange. This
+ * means each sub exchange has its own individual unit of work.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param shareUnitOfWork the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder shareUnitOfWork(
+ boolean shareUnitOfWork) {
+ doSetProperty("shareUnitOfWork", shareUnitOfWork);
+ return this;
+ }
+ /**
+ * Shares the org.apache.camel.spi.UnitOfWork with the parent and each
+ * of the sub messages. Multicast will, by default, not share a unit of
+ * work between the parent exchange and each multicasted exchange. This
+ * means each sub exchange has its own individual unit of work.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param shareUnitOfWork the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder shareUnitOfWork(
+ String shareUnitOfWork) {
+ doSetProperty("shareUnitOfWork", shareUnitOfWork);
+ return this;
+ }
+ /**
+ * Will 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 message), or an exception was thrown and handled
+ * by the error handler (such as using onException). In all situations,
+ * the multicast will stop further processing. This is the same behavior
+ * as in the pipeline that is used by the routing engine. The default
+ * behavior is to not stop, but to continue processing until the end.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param stopOnException the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder stopOnException(
+ boolean stopOnException) {
+ doSetProperty("stopOnException", stopOnException);
+ return this;
+ }
+ /**
+ * Will 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 message), or an exception was thrown and handled
+ * by the error handler (such as using onException). In all situations,
+ * the multicast will stop further processing. This is the same behavior
+ * as in the pipeline that is used by the routing engine. The default
+ * behavior is to not stop, but to continue processing until the end.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param stopOnException the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder stopOnException(
+ String stopOnException) {
+ doSetProperty("stopOnException", stopOnException);
+ return this;
+ }
+ /**
+ * If enabled, then Camel will process replies out-of-order (e.g., in
+ * the order they come back). If disabled, Camel will process replies in
+ * the same order as defined by the multicast.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param streaming the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder streaming(boolean streaming) {
+ doSetProperty("streaming", streaming);
+ return this;
+ }
+ /**
+ * If enabled, then Camel will process replies out-of-order (e.g., in
+ * the order they come back). If disabled, Camel will process replies in
+ * the same order as defined by the multicast.
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: false
+ * Group: common
+ *
+ * @param streaming the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder streaming(String streaming) {
+ doSetProperty("streaming", streaming);
+ return this;
+ }
+ /**
+ * 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.
*
* The option is a: <code>boolean</code> type.
*
@@ -75,7 +380,9 @@ public interface DynamicRouterEndpointBuilderFactory {
return this;
}
/**
- * Flag to ensure synchronous processing.
+ * 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.
*
* The option will be converted to a <code>boolean</code>
* type.
@@ -90,6 +397,52 @@ public interface DynamicRouterEndpointBuilderFactory {
doSetProperty("synchronous", synchronous);
return this;
}
+ /**
+ * Sets a total timeout specified in milliseconds, when using parallel
+ * processing. If the Multicast has not been able to send and process
+ * all replies within the given timeframe, then the timeout triggers and
+ * the Multicast breaks out and continues. Notice that, if you provide a
+ * TimeoutAwareAggregationStrategy, then the timeout method is invoked
+ * before breaking out. If the timeout is reached with running tasks
+ * still remaining, certain tasks (for which it is difficult for Camel
+ * to shut down in a graceful manner) may continue to run. So use this
+ * option with a bit of care.
+ *
+ * The option is a: <code>long</code> type.
+ *
+ * Default: -1
+ * Group: common
+ *
+ * @param timeout the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder timeout(long timeout) {
+ doSetProperty("timeout", timeout);
+ return this;
+ }
+ /**
+ * Sets a total timeout specified in milliseconds, when using parallel
+ * processing. If the Multicast has not been able to send and process
+ * all replies within the given timeframe, then the timeout triggers and
+ * the Multicast breaks out and continues. Notice that, if you provide a
+ * TimeoutAwareAggregationStrategy, then the timeout method is invoked
+ * before breaking out. If the timeout is reached with running tasks
+ * still remaining, certain tasks (for which it is difficult for Camel
+ * to shut down in a graceful manner) may continue to run. So use this
+ * option with a bit of care.
+ *
+ * The option will be converted to a <code>long</code> type.
+ *
+ * Default: -1
+ * Group: common
+ *
+ * @param timeout the value to set
+ * @return the dsl builder
+ */
+ default DynamicRouterEndpointBuilder timeout(String timeout) {
+ doSetProperty("timeout", timeout);
+ return this;
+ }
/**
* Flag to log a warning if no predicates match for an exchange.
*
diff --git a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java
index c5db0313347..0a2c2d6e509 100644
--- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java
+++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PlatformHttpEndpointBuilderFactory.java
@@ -160,7 +160,8 @@ public interface PlatformHttpEndpointBuilderFactory {
return this;
}
/**
- * Whether to use streaming for large requests and responses.
+ * Whether to use streaming for large requests and responses (currently
+ * only supported by camel-platform-http-vertx).
*
* The option is a: <code>boolean</code> type.
*
@@ -175,7 +176,8 @@ public interface PlatformHttpEndpointBuilderFactory {
return this;
}
/**
- * Whether to use streaming for large requests and responses.
+ * Whether to use streaming for large requests and responses (currently
+ * only supported by camel-platform-http-vertx).
*
* The option will be converted to a <code>boolean</code>
* type.