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
The following commit(s) were added to refs/heads/main by this push: new a7a4e2373fd Regen a7a4e2373fd is described below commit a7a4e2373fda2b3547cdf231550cd1a899b3af7f Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Jan 12 09:43:07 2023 +0100 Regen --- camel-dependencies/pom.xml | 2 +- .../dsl/NettyComponentBuilderFactory.java | 40 ++++++++++++++++++++++ .../dsl/NettyHttpComponentBuilderFactory.java | 40 ++++++++++++++++++++++ 3 files changed, 81 insertions(+), 1 deletion(-) diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml index 490c5380eff..2f7931bc7ec 100644 --- a/camel-dependencies/pom.xml +++ b/camel-dependencies/pom.xml @@ -438,7 +438,7 @@ <pgjdbc-ng-driver-version>0.8.9</pgjdbc-ng-driver-version> <picocli-version>4.7.0</picocli-version> <plc4x-version>0.10.0</plc4x-version> - <pooled-jms-version>1.2.4</pooled-jms-version> + <pooled-jms-version>3.0.0</pooled-jms-version> <powermock-version>2.0.7</powermock-version> <properties-maven-plugin-version>1.0-alpha-2</properties-maven-plugin-version> <protobuf-version>3.19.6</protobuf-version> diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyComponentBuilderFactory.java index 5d6ddbb9ac3..8b42424d860 100644 --- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyComponentBuilderFactory.java +++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyComponentBuilderFactory.java @@ -597,6 +597,25 @@ public interface NettyComponentBuilderFactory { doSetProperty("lazyChannelCreation", lazyChannelCreation); return this; } + /** + * Sets the value for the blockWhenExhausted configuration attribute. It + * determines whether to block when the borrowObject() method is invoked + * when the pool is exhausted (the maximum number of active objects has + * been reached). + * + * The option is a: <code>boolean</code> type. + * + * Default: true + * Group: producer (advanced) + * + * @param producerPoolBlockWhenExhausted the value to set + * @return the dsl builder + */ + default NettyComponentBuilder producerPoolBlockWhenExhausted( + boolean producerPoolBlockWhenExhausted) { + doSetProperty("producerPoolBlockWhenExhausted", producerPoolBlockWhenExhausted); + return this; + } /** * Whether producer pool is enabled or not. Important: If you turn this * off then a single shared connection is used for the producer, also if @@ -657,6 +676,25 @@ public interface NettyComponentBuilderFactory { doSetProperty("producerPoolMaxTotal", producerPoolMaxTotal); return this; } + /** + * Sets the maximum duration (value in millis) the borrowObject() method + * should block before throwing an exception when the pool is exhausted + * and producerPoolBlockWhenExhausted is true. When less than 0, the + * borrowObject() method may block indefinitely. + * + * The option is a: <code>long</code> type. + * + * Default: -1 + * Group: producer (advanced) + * + * @param producerPoolMaxWait the value to set + * @return the dsl builder + */ + default NettyComponentBuilder producerPoolMaxWait( + long producerPoolMaxWait) { + doSetProperty("producerPoolMaxWait", producerPoolMaxWait); + return this; + } /** * Sets the minimum amount of time (value in millis) an object may sit * idle in the pool before it is eligible for eviction by the idle @@ -1370,9 +1408,11 @@ public interface NettyComponentBuilderFactory { case "clientInitializerFactory": getOrCreateConfiguration((NettyComponent) component).setClientInitializerFactory((org.apache.camel.component.netty.ClientInitializerFactory) value); return true; case "correlationManager": getOrCreateConfiguration((NettyComponent) component).setCorrelationManager((org.apache.camel.component.netty.NettyCamelStateCorrelationManager) value); return true; case "lazyChannelCreation": getOrCreateConfiguration((NettyComponent) component).setLazyChannelCreation((boolean) value); return true; + case "producerPoolBlockWhenExhausted": getOrCreateConfiguration((NettyComponent) component).setProducerPoolBlockWhenExhausted((boolean) value); return true; case "producerPoolEnabled": getOrCreateConfiguration((NettyComponent) component).setProducerPoolEnabled((boolean) value); return true; case "producerPoolMaxIdle": getOrCreateConfiguration((NettyComponent) component).setProducerPoolMaxIdle((int) value); return true; case "producerPoolMaxTotal": getOrCreateConfiguration((NettyComponent) component).setProducerPoolMaxTotal((int) value); return true; + case "producerPoolMaxWait": getOrCreateConfiguration((NettyComponent) component).setProducerPoolMaxWait((long) value); return true; case "producerPoolMinEvictableIdle": getOrCreateConfiguration((NettyComponent) component).setProducerPoolMinEvictableIdle((long) value); return true; case "producerPoolMinIdle": getOrCreateConfiguration((NettyComponent) component).setProducerPoolMinIdle((int) value); return true; case "udpConnectionlessSending": getOrCreateConfiguration((NettyComponent) component).setUdpConnectionlessSending((boolean) value); return true; diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyHttpComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyHttpComponentBuilderFactory.java index 83a5bd733f4..5e964520c76 100644 --- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyHttpComponentBuilderFactory.java +++ b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/NettyHttpComponentBuilderFactory.java @@ -616,6 +616,25 @@ public interface NettyHttpComponentBuilderFactory { doSetProperty("lazyChannelCreation", lazyChannelCreation); return this; } + /** + * Sets the value for the blockWhenExhausted configuration attribute. It + * determines whether to block when the borrowObject() method is invoked + * when the pool is exhausted (the maximum number of active objects has + * been reached). + * + * The option is a: <code>boolean</code> type. + * + * Default: true + * Group: producer (advanced) + * + * @param producerPoolBlockWhenExhausted the value to set + * @return the dsl builder + */ + default NettyHttpComponentBuilder producerPoolBlockWhenExhausted( + boolean producerPoolBlockWhenExhausted) { + doSetProperty("producerPoolBlockWhenExhausted", producerPoolBlockWhenExhausted); + return this; + } /** * Whether producer pool is enabled or not. Important: If you turn this * off then a single shared connection is used for the producer, also if @@ -676,6 +695,25 @@ public interface NettyHttpComponentBuilderFactory { doSetProperty("producerPoolMaxTotal", producerPoolMaxTotal); return this; } + /** + * Sets the maximum duration (value in millis) the borrowObject() method + * should block before throwing an exception when the pool is exhausted + * and producerPoolBlockWhenExhausted is true. When less than 0, the + * borrowObject() method may block indefinitely. + * + * The option is a: <code>long</code> type. + * + * Default: -1 + * Group: producer (advanced) + * + * @param producerPoolMaxWait the value to set + * @return the dsl builder + */ + default NettyHttpComponentBuilder producerPoolMaxWait( + long producerPoolMaxWait) { + doSetProperty("producerPoolMaxWait", producerPoolMaxWait); + return this; + } /** * Sets the minimum amount of time (value in millis) an object may sit * idle in the pool before it is eligible for eviction by the idle @@ -1449,9 +1487,11 @@ public interface NettyHttpComponentBuilderFactory { case "clientInitializerFactory": getOrCreateConfiguration((NettyHttpComponent) component).setClientInitializerFactory((org.apache.camel.component.netty.ClientInitializerFactory) value); return true; case "correlationManager": getOrCreateConfiguration((NettyHttpComponent) component).setCorrelationManager((org.apache.camel.component.netty.NettyCamelStateCorrelationManager) value); return true; case "lazyChannelCreation": getOrCreateConfiguration((NettyHttpComponent) component).setLazyChannelCreation((boolean) value); return true; + case "producerPoolBlockWhenExhausted": getOrCreateConfiguration((NettyHttpComponent) component).setProducerPoolBlockWhenExhausted((boolean) value); return true; case "producerPoolEnabled": getOrCreateConfiguration((NettyHttpComponent) component).setProducerPoolEnabled((boolean) value); return true; case "producerPoolMaxIdle": getOrCreateConfiguration((NettyHttpComponent) component).setProducerPoolMaxIdle((int) value); return true; case "producerPoolMaxTotal": getOrCreateConfiguration((NettyHttpComponent) component).setProducerPoolMaxTotal((int) value); return true; + case "producerPoolMaxWait": getOrCreateConfiguration((NettyHttpComponent) component).setProducerPoolMaxWait((long) value); return true; case "producerPoolMinEvictableIdle": getOrCreateConfiguration((NettyHttpComponent) component).setProducerPoolMinEvictableIdle((long) value); return true; case "producerPoolMinIdle": getOrCreateConfiguration((NettyHttpComponent) component).setProducerPoolMinIdle((int) value); return true; case "udpConnectionlessSending": getOrCreateConfiguration((NettyHttpComponent) component).setUdpConnectionlessSending((boolean) value); return true;