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 <claus.ib...@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.
