This is an automated email from the ASF dual-hosted git repository.
Croway 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 d4e8e94c2221 camel-seda: defaultOfferTimeout carried blockWhenFull's
description (#29492)
d4e8e94c2221 is described below
commit d4e8e94c222134d9f713efe6849ed6d1f664d951
Author: dhairya05 <[email protected]>
AuthorDate: Tue Nov 10 16:16:36 2026 +0530
camel-seda: defaultOfferTimeout carried blockWhenFull's description (#29492)
* camel-seda: defaultOfferTimeout carried blockWhenFull's description
defaultOfferTimeout is a long holding a timeout, but its description was
defaultBlockWhenFull's text: "Whether a thread that sends messages to a
full SEDA queue will block until the queue's capacity is no longer
exhausted...". That describes a boolean toggle, and its tail "By
enabling this option, where a configured timeout can be added to the
block case" is left ungrammatical by the splice.
Reworded after the endpoint's own offerTimeout option, which is the same
setting at endpoint level, following how defaultBlockWhenFull and
defaultDiscardWhenFull reuse their endpoint counterparts' wording.
camel-stub inherits the component options from SedaComponent, so its
generated files are updated too.
* camel-seda: offerTimeout descriptions follow SedaProducer.offerToQueue
Per review: a negative offerTimeout does not disable the timeout, it
falls through to queue.add() and so disables blocking. Reword both the
component's defaultOfferTimeout and the endpoint's offerTimeout after
the code: the value is used when blockWhenFull is enabled and the queue
is full, and the default 0 blocks without a timeout. The component option
is a plain long, so it now says milliseconds.
---
.../resources/org/apache/camel/catalog/components/seda.json | 4 ++--
.../resources/org/apache/camel/catalog/components/stub.json | 4 ++--
.../META-INF/org/apache/camel/component/seda/seda.json | 4 ++--
.../java/org/apache/camel/component/seda/SedaComponent.java | 11 ++++-------
.../java/org/apache/camel/component/seda/SedaEndpoint.java | 8 ++++----
.../META-INF/org/apache/camel/component/stub/stub.json | 4 ++--
.../builder/component/dsl/SedaComponentBuilderFactory.java | 8 +++-----
.../builder/component/dsl/StubComponentBuilderFactory.java | 8 +++-----
.../builder/endpoint/dsl/SedaEndpointBuilderFactory.java | 8 ++++----
.../builder/endpoint/dsl/StubEndpointBuilderFactory.java | 8 ++++----
10 files changed, 30 insertions(+), 37 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/seda.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/seda.json
index b723961c5a8c..53fee1397117 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/seda.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/seda.json
@@ -31,7 +31,7 @@
"lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
"defaultBlockWhenFull": { "index": 4, "kind": "property", "displayName":
"Default Block When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will block until the queue's capacity is no longer exhausted.
By default, an exception will be thrown stating [...]
"defaultDiscardWhenFull": { "index": 5, "kind": "property", "displayName":
"Default Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling thi [...]
- "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description":
"Whether a thread that sends messages to a full SEDA queue will block until the
queue's capacity is no longer exhausted. By default, an exception will be
thrown stating that the queue is full. By en [...]
+ "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default offer timeout (in milliseconds) used when blockWhenFull is enabled
and the queue is full. The default 0 blocks without a timeout." },
"autowiredEnabled": { "index": 7, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
"defaultQueueFactory": { "index": 8, "kind": "property", "displayName":
"Default Queue Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default queue factory." },
"queueSize": { "index": 9, "kind": "property", "displayName": "Queue
Size", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "description": "Sets the default maximum
capacity of the SEDA queue (i.e., the number of messages it can hold)." }
@@ -60,7 +60,7 @@
"discardWhenFull": { "index": 15, "kind": "parameter", "displayName":
"Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling this option, the [...]
"failIfNoConsumers": { "index": 16, "kind": "parameter", "displayName":
"Fail If No Consumers", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should fail by
throwing an exception, when sending to a queue with no active consumers. Only
one of the options discardIfNoConsumers and failIfNoConsum [...]
"lazyStartProducer": { "index": 17, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
- "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout can be added
to the block case when queue is full. You can disable timeout by using 0 or a
negative value." },
+ "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout used when
blockWhenFull is enabled and the queue is full. The default 0 blocks without a
timeout." },
"browseLimit": { "index": 19, "kind": "parameter", "displayName": "Browse
Limit", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 100, "description": "Maximum number of
messages to keep in memory available for browsing. Use 0 for unlimited." },
"queue": { "index": 20, "kind": "parameter", "displayName": "Queue",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "java.util.concurrent.BlockingQueue<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description":
"Define the queue instance which will be used by the endpoint" }
}
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/stub.json
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/stub.json
index 06ee7ea6b3db..8940b9389e0f 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/stub.json
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/stub.json
@@ -31,7 +31,7 @@
"lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
"defaultBlockWhenFull": { "index": 4, "kind": "property", "displayName":
"Default Block When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will block until the queue's capacity is no longer exhausted.
By default, an exception will be thrown stating [...]
"defaultDiscardWhenFull": { "index": 5, "kind": "property", "displayName":
"Default Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling thi [...]
- "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description":
"Whether a thread that sends messages to a full SEDA queue will block until the
queue's capacity is no longer exhausted. By default, an exception will be
thrown stating that the queue is full. By en [...]
+ "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default offer timeout (in milliseconds) used when blockWhenFull is enabled
and the queue is full. The default 0 blocks without a timeout." },
"autowiredEnabled": { "index": 7, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
"defaultQueueFactory": { "index": 8, "kind": "property", "displayName":
"Default Queue Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default queue factory." },
"queueSize": { "index": 9, "kind": "property", "displayName": "Queue
Size", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "description": "Sets the default maximum
capacity of the SEDA queue (i.e., the number of messages it can hold)." },
@@ -62,7 +62,7 @@
"discardWhenFull": { "index": 15, "kind": "parameter", "displayName":
"Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling this option, the [...]
"failIfNoConsumers": { "index": 16, "kind": "parameter", "displayName":
"Fail If No Consumers", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should fail by
throwing an exception, when sending to a queue with no active consumers. Only
one of the options discardIfNoConsumers and failIfNoConsum [...]
"lazyStartProducer": { "index": 17, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
- "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout can be added
to the block case when queue is full. You can disable timeout by using 0 or a
negative value." },
+ "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout used when
blockWhenFull is enabled and the queue is full. The default 0 blocks without a
timeout." },
"browseLimit": { "index": 19, "kind": "parameter", "displayName": "Browse
Limit", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 100, "description": "Maximum number of
messages to keep in memory available for browsing. Use 0 for unlimited." },
"queue": { "index": 20, "kind": "parameter", "displayName": "Queue",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "java.util.concurrent.BlockingQueue<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description":
"Define the queue instance which will be used by the endpoint" }
}
diff --git
a/components/camel-seda/src/generated/resources/META-INF/org/apache/camel/component/seda/seda.json
b/components/camel-seda/src/generated/resources/META-INF/org/apache/camel/component/seda/seda.json
index b723961c5a8c..53fee1397117 100644
---
a/components/camel-seda/src/generated/resources/META-INF/org/apache/camel/component/seda/seda.json
+++
b/components/camel-seda/src/generated/resources/META-INF/org/apache/camel/component/seda/seda.json
@@ -31,7 +31,7 @@
"lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
"defaultBlockWhenFull": { "index": 4, "kind": "property", "displayName":
"Default Block When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will block until the queue's capacity is no longer exhausted.
By default, an exception will be thrown stating [...]
"defaultDiscardWhenFull": { "index": 5, "kind": "property", "displayName":
"Default Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling thi [...]
- "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description":
"Whether a thread that sends messages to a full SEDA queue will block until the
queue's capacity is no longer exhausted. By default, an exception will be
thrown stating that the queue is full. By en [...]
+ "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default offer timeout (in milliseconds) used when blockWhenFull is enabled
and the queue is full. The default 0 blocks without a timeout." },
"autowiredEnabled": { "index": 7, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
"defaultQueueFactory": { "index": 8, "kind": "property", "displayName":
"Default Queue Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default queue factory." },
"queueSize": { "index": 9, "kind": "property", "displayName": "Queue
Size", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "description": "Sets the default maximum
capacity of the SEDA queue (i.e., the number of messages it can hold)." }
@@ -60,7 +60,7 @@
"discardWhenFull": { "index": 15, "kind": "parameter", "displayName":
"Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling this option, the [...]
"failIfNoConsumers": { "index": 16, "kind": "parameter", "displayName":
"Fail If No Consumers", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should fail by
throwing an exception, when sending to a queue with no active consumers. Only
one of the options discardIfNoConsumers and failIfNoConsum [...]
"lazyStartProducer": { "index": 17, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
- "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout can be added
to the block case when queue is full. You can disable timeout by using 0 or a
negative value." },
+ "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout used when
blockWhenFull is enabled and the queue is full. The default 0 blocks without a
timeout." },
"browseLimit": { "index": 19, "kind": "parameter", "displayName": "Browse
Limit", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 100, "description": "Maximum number of
messages to keep in memory available for browsing. Use 0 for unlimited." },
"queue": { "index": 20, "kind": "parameter", "displayName": "Queue",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "java.util.concurrent.BlockingQueue<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description":
"Define the queue instance which will be used by the endpoint" }
}
diff --git
a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaComponent.java
b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaComponent.java
index 224629ac2a3e..24d834de4c4c 100644
---
a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaComponent.java
+++
b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaComponent.java
@@ -57,9 +57,8 @@ public class SedaComponent extends DefaultComponent {
+ " continue, meaning that the message was not
sent to the SEDA queue.")
private boolean defaultDiscardWhenFull;
@Metadata(label = "producer,advanced",
- description = "Whether a thread that sends messages to a full
SEDA queue will block until the queue's capacity is no longer"
- + " exhausted. By default, an exception will be
thrown stating that the queue is full. By enabling this option, where"
- + " a configured timeout can be added to the block
case. Using the offer(timeout) method of the underlining java queue")
+ description = "Sets the default offer timeout (in milliseconds)
used when blockWhenFull is enabled and the queue"
+ + " is full. The default 0 blocks without a
timeout.")
private long defaultOfferTimeout;
@Metadata(label = "consumer,advanced", defaultValue = "1000",
description = "The timeout (in milliseconds) used when polling.
When a timeout occurs, the consumer can check whether it is"
@@ -136,10 +135,8 @@ public class SedaComponent extends DefaultComponent {
}
/**
- * Whether a thread that sends messages to a full SEDA queue will block
until the queue's capacity is no longer
- * exhausted. By default, an exception will be thrown stating that the
queue is full. By enabling this option, where
- * a configured timeout can be added to the block case. Using the
.offer(timeout) method of the underlining java
- * queue
+ * Sets the default offer timeout (in milliseconds) used when
blockWhenFull is enabled and the queue is full. The
+ * default 0 blocks without a timeout.
*/
public void setDefaultOfferTimeout(long defaultOfferTimeout) {
this.defaultOfferTimeout = defaultOfferTimeout;
diff --git
a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
index 652503eb4be3..4e1caeb18393 100644
---
a/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
+++
b/components/camel-seda/src/main/java/org/apache/camel/component/seda/SedaEndpoint.java
@@ -135,8 +135,8 @@ public class SedaEndpoint extends DefaultEndpoint
implements AsyncEndpoint, Brow
+ " disable timeout by using 0 or a negative
value.")
private long timeout = 30000;
@UriParam(label = "producer,advanced", javaType = "java.time.Duration",
- description = "Offer timeout can be added to the block case when
queue is full. You can disable timeout by"
- + " using 0 or a negative value.")
+ description = "Offer timeout used when blockWhenFull is enabled
and the queue is full. The default 0 blocks"
+ + " without a timeout.")
private long offerTimeout;
@UriParam(label = "producer,advanced",
description = "Whether a thread that sends messages to a full
SEDA queue will block until the queue's capacity is no longer"
@@ -528,8 +528,8 @@ public class SedaEndpoint extends DefaultEndpoint
implements AsyncEndpoint, Brow
}
/**
- * Offer timeout (in milliseconds) can be added to the block case when
queue is full. You can disable timeout by
- * using 0 or a negative value.
+ * Offer timeout (in milliseconds) used when blockWhenFull is enabled and
the queue is full. The default 0 blocks
+ * without a timeout.
*/
public void setOfferTimeout(long offerTimeout) {
this.offerTimeout = offerTimeout;
diff --git
a/components/camel-stub/src/generated/resources/META-INF/org/apache/camel/component/stub/stub.json
b/components/camel-stub/src/generated/resources/META-INF/org/apache/camel/component/stub/stub.json
index 06ee7ea6b3db..8940b9389e0f 100644
---
a/components/camel-stub/src/generated/resources/META-INF/org/apache/camel/component/stub/stub.json
+++
b/components/camel-stub/src/generated/resources/META-INF/org/apache/camel/component/stub/stub.json
@@ -31,7 +31,7 @@
"lazyStartProducer": { "index": 3, "kind": "property", "displayName":
"Lazy Start Producer", "group": "producer", "label": "producer", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": false, "description":
"Whether the producer should be started lazy (on the first message). By
starting lazy you can use this to allow CamelContext and routes to startup in
situations where a producer may otherwise fail [...]
"defaultBlockWhenFull": { "index": 4, "kind": "property", "displayName":
"Default Block When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will block until the queue's capacity is no longer exhausted.
By default, an exception will be thrown stating [...]
"defaultDiscardWhenFull": { "index": 5, "kind": "property", "displayName":
"Default Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling thi [...]
- "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description":
"Whether a thread that sends messages to a full SEDA queue will block until the
queue's capacity is no longer exhausted. By default, an exception will be
thrown stating that the queue is full. By en [...]
+ "defaultOfferTimeout": { "index": 6, "kind": "property", "displayName":
"Default Offer Timeout", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default offer timeout (in milliseconds) used when blockWhenFull is enabled
and the queue is full. The default 0 blocks without a timeout." },
"autowiredEnabled": { "index": 7, "kind": "property", "displayName":
"Autowired Enabled", "group": "advanced", "label": "advanced", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Whether autowiring is enabled. This is used for automatic autowiring options
(the option must be marked as autowired) by looking up in the registry to find
if there is a single instance of matching t [...]
"defaultQueueFactory": { "index": 8, "kind": "property", "displayName":
"Default Queue Factory", "group": "advanced", "label": "advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.component.seda.BlockingQueueFactory<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the default queue factory." },
"queueSize": { "index": 9, "kind": "property", "displayName": "Queue
Size", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1000, "description": "Sets the default maximum
capacity of the SEDA queue (i.e., the number of messages it can hold)." },
@@ -62,7 +62,7 @@
"discardWhenFull": { "index": 15, "kind": "parameter", "displayName":
"Discard When Full", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether a thread that sends messages to
a full SEDA queue will be discarded. By default, an exception will be thrown
stating that the queue is full. By enabling this option, the [...]
"failIfNoConsumers": { "index": 16, "kind": "parameter", "displayName":
"Fail If No Consumers", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should fail by
throwing an exception, when sending to a queue with no active consumers. Only
one of the options discardIfNoConsumers and failIfNoConsum [...]
"lazyStartProducer": { "index": 17, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
- "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout can be added
to the block case when queue is full. You can disable timeout by using 0 or a
negative value." },
+ "offerTimeout": { "index": 18, "kind": "parameter", "displayName": "Offer
Timeout", "group": "producer (advanced)", "label": "producer,advanced",
"required": false, "type": "duration", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "description": "Offer timeout used when
blockWhenFull is enabled and the queue is full. The default 0 blocks without a
timeout." },
"browseLimit": { "index": 19, "kind": "parameter", "displayName": "Browse
Limit", "group": "advanced", "label": "advanced", "required": false, "type":
"integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 100, "description": "Maximum number of
messages to keep in memory available for browsing. Use 0 for unlimited." },
"queue": { "index": 20, "kind": "parameter", "displayName": "Queue",
"group": "advanced", "label": "advanced", "required": false, "type": "object",
"javaType": "java.util.concurrent.BlockingQueue<org.apache.camel.Exchange>",
"deprecated": false, "autowired": false, "secret": false, "description":
"Define the queue instance which will be used by the endpoint" }
}
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/SedaComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/SedaComponentBuilderFactory.java
index 74e7d0dc4037..f62ae5f3e4e3 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/SedaComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/SedaComponentBuilderFactory.java
@@ -184,11 +184,9 @@ public interface SedaComponentBuilderFactory {
}
/**
- * Whether a thread that sends messages to a full SEDA queue will block
- * until the queue's capacity is no longer exhausted. By default, an
- * exception will be thrown stating that the queue is full. By enabling
- * this option, where a configured timeout can be added to the block
- * case. Using the offer(timeout) method of the underlining java queue.
+ * Sets the default offer timeout (in milliseconds) used when
+ * blockWhenFull is enabled and the queue is full. The default 0 blocks
+ * without a timeout.
*
* The option is a: <code>long</code> type.
*
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StubComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StubComponentBuilderFactory.java
index 0e24c5693107..1ed7daa5ef6e 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StubComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/StubComponentBuilderFactory.java
@@ -183,11 +183,9 @@ public interface StubComponentBuilderFactory {
}
/**
- * Whether a thread that sends messages to a full SEDA queue will block
- * until the queue's capacity is no longer exhausted. By default, an
- * exception will be thrown stating that the queue is full. By enabling
- * this option, where a configured timeout can be added to the block
- * case. Using the offer(timeout) method of the underlining java queue.
+ * Sets the default offer timeout (in milliseconds) used when
+ * blockWhenFull is enabled and the queue is full. The default 0 blocks
+ * without a timeout.
*
* The option is a: <code>long</code> type.
*
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/SedaEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/SedaEndpointBuilderFactory.java
index cb37cd872dfb..9e4443d5371a 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/SedaEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/SedaEndpointBuilderFactory.java
@@ -812,8 +812,8 @@ public interface SedaEndpointBuilderFactory {
return this;
}
/**
- * Offer timeout can be added to the block case when queue is full. You
- * can disable timeout by using 0 or a negative value.
+ * Offer timeout used when blockWhenFull is enabled and the queue is
+ * full. The default 0 blocks without a timeout.
*
* The option is a: <code>long</code> type.
*
@@ -827,8 +827,8 @@ public interface SedaEndpointBuilderFactory {
return this;
}
/**
- * Offer timeout can be added to the block case when queue is full. You
- * can disable timeout by using 0 or a negative value.
+ * Offer timeout used when blockWhenFull is enabled and the queue is
+ * full. The default 0 blocks without a timeout.
*
* The option will be converted to a <code>long</code> type.
*
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StubEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StubEndpointBuilderFactory.java
index ce3feb0e1ab1..793c181b9817 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StubEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/StubEndpointBuilderFactory.java
@@ -812,8 +812,8 @@ public interface StubEndpointBuilderFactory {
return this;
}
/**
- * Offer timeout can be added to the block case when queue is full. You
- * can disable timeout by using 0 or a negative value.
+ * Offer timeout used when blockWhenFull is enabled and the queue is
+ * full. The default 0 blocks without a timeout.
*
* The option is a: <code>long</code> type.
*
@@ -827,8 +827,8 @@ public interface StubEndpointBuilderFactory {
return this;
}
/**
- * Offer timeout can be added to the block case when queue is full. You
- * can disable timeout by using 0 or a negative value.
+ * Offer timeout used when blockWhenFull is enabled and the queue is
+ * full. The default 0 blocks without a timeout.
*
* The option will be converted to a <code>long</code> type.
*
