This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 61e22088eb583997f89872c4cfb825bc9c2a92f3
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Thu Feb 11 14:29:04 2021 +0100
CAMEL-16186 - Camel-AWS2-SQS: Support String as body for batch message
---
.../apache/camel/catalog/docs/aws2-sqs-component.adoc | 6 ++++--
.../component/aws2/sqs/Sqs2ComponentConfigurer.java | 6 ++++++
.../component/aws2/sqs/Sqs2EndpointConfigurer.java | 6 ++++++
.../component/aws2/sqs/Sqs2EndpointUriFactory.java | 3 ++-
.../org/apache/camel/component/aws2/sqs/aws2-sqs.json | 2 ++
.../src/main/docs/aws2-sqs-component.adoc | 6 ++++--
.../camel/component/aws2/sqs/Sqs2Configuration.java | 16 ++++++++--------
.../component/dsl/Aws2SqsComponentBuilderFactory.java | 18 ++++++++++++++++++
.../endpoint/dsl/Sqs2EndpointBuilderFactory.java | 16 ++++++++++++++++
.../modules/ROOT/pages/aws2-sqs-component.adoc | 6 ++++--
10 files changed, 70 insertions(+), 15 deletions(-)
diff --git
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc
index 7d2a718..9a38a61 100644
---
a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc
+++
b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc
@@ -43,7 +43,7 @@ The queue will be created if they don't already exists. +
// component options: START
-The AWS 2 Simple Queue Service (SQS) component supports 40 options, which are
listed below.
+The AWS 2 Simple Queue Service (SQS) component supports 41 options, which are
listed below.
@@ -73,6 +73,7 @@ The AWS 2 Simple Queue Service (SQS) component supports 40
options, which are li
| *serverSideEncryptionEnabled* (consumer) | Define if Server Side Encryption
is enabled or not on the queue | false | boolean
| *visibilityTimeout* (consumer) | The duration (in seconds) that the received
messages are hidden from subsequent retrieve requests after being retrieved by
a ReceiveMessage request to set in the
com.amazonaws.services.sqs.model.SetQueueAttributesRequest. This only make
sense if its different from defaultVisibilityTimeout. It changes the queue
visibility timeout attribute permanently. | | Integer
| *waitTimeSeconds* (consumer) | Duration in seconds (0 to 20) that the
ReceiveMessage action call will wait until a message is in the queue to include
in the response. | | Integer
+| *batchSeparator* (producer) | Set the separator when passing a String to
send batch message operation | , | String
| *delaySeconds* (producer) | Delay sending messages for a number of seconds.
| | Integer
| *lazyStartProducer* (producer) | 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 during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
@@ -119,7 +120,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (58 parameters):
+=== Query Parameters (59 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -153,6 +154,7 @@ with the following path and query parameters:
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *pollStrategy* (consumer) | A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel.
| | PollingConsumerPollStrategy
+| *batchSeparator* (producer) | Set the separator when passing a String to
send batch message operation | , | String
| *delaySeconds* (producer) | Delay sending messages for a number of seconds.
| | Integer
| *lazyStartProducer* (producer) | 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 during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
diff --git
a/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2ComponentConfigurer.java
b/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2ComponentConfigurer.java
index c02f1cf..622e046 100644
---
a/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2ComponentConfigurer.java
+++
b/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2ComponentConfigurer.java
@@ -40,6 +40,8 @@ public class Sqs2ComponentConfigurer extends
PropertyConfigurerSupport implement
case "autoCreateQueue":
getOrCreateConfiguration(target).setAutoCreateQueue(property(camelContext,
boolean.class, value)); return true;
case "autowiredenabled":
case "autowiredEnabled":
target.setAutowiredEnabled(property(camelContext, boolean.class, value));
return true;
+ case "batchseparator":
+ case "batchSeparator":
getOrCreateConfiguration(target).setBatchSeparator(property(camelContext,
java.lang.String.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
case "concurrentconsumers":
@@ -127,6 +129,8 @@ public class Sqs2ComponentConfigurer extends
PropertyConfigurerSupport implement
case "autoCreateQueue": return boolean.class;
case "autowiredenabled":
case "autowiredEnabled": return boolean.class;
+ case "batchseparator":
+ case "batchSeparator": return java.lang.String.class;
case "bridgeerrorhandler":
case "bridgeErrorHandler": return boolean.class;
case "concurrentconsumers":
@@ -210,6 +214,8 @@ public class Sqs2ComponentConfigurer extends
PropertyConfigurerSupport implement
case "autoCreateQueue": return
getOrCreateConfiguration(target).isAutoCreateQueue();
case "autowiredenabled":
case "autowiredEnabled": return target.isAutowiredEnabled();
+ case "batchseparator":
+ case "batchSeparator": return
getOrCreateConfiguration(target).getBatchSeparator();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
case "concurrentconsumers":
diff --git
a/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
b/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
index 0fc2585..941ecf2 100644
---
a/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
+++
b/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
@@ -37,6 +37,8 @@ public class Sqs2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "backoffIdleThreshold":
target.setBackoffIdleThreshold(property(camelContext, int.class, value));
return true;
case "backoffmultiplier":
case "backoffMultiplier":
target.setBackoffMultiplier(property(camelContext, int.class, value)); return
true;
+ case "batchseparator":
+ case "batchSeparator":
target.getConfiguration().setBatchSeparator(property(camelContext,
java.lang.String.class, value)); return true;
case "bridgeerrorhandler":
case "bridgeErrorHandler":
target.setBridgeErrorHandler(property(camelContext, boolean.class, value));
return true;
case "concurrentconsumers":
@@ -158,6 +160,8 @@ public class Sqs2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "backoffIdleThreshold": return int.class;
case "backoffmultiplier":
case "backoffMultiplier": return int.class;
+ case "batchseparator":
+ case "batchSeparator": return java.lang.String.class;
case "bridgeerrorhandler":
case "bridgeErrorHandler": return boolean.class;
case "concurrentconsumers":
@@ -275,6 +279,8 @@ public class Sqs2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "backoffIdleThreshold": return target.getBackoffIdleThreshold();
case "backoffmultiplier":
case "backoffMultiplier": return target.getBackoffMultiplier();
+ case "batchseparator":
+ case "batchSeparator": return
target.getConfiguration().getBatchSeparator();
case "bridgeerrorhandler":
case "bridgeErrorHandler": return target.isBridgeErrorHandler();
case "concurrentconsumers":
diff --git
a/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
b/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
index 5ed24a4..81879a6 100644
---
a/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
+++
b/components/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
@@ -20,7 +20,7 @@ public class Sqs2EndpointUriFactory extends
org.apache.camel.support.component.E
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(59);
+ Set<String> props = new HashSet<>(60);
props.add("queueUrl");
props.add("initialDelay");
props.add("proxyPort");
@@ -52,6 +52,7 @@ public class Sqs2EndpointUriFactory extends
org.apache.camel.support.component.E
props.add("backoffMultiplier");
props.add("maximumMessageSize");
props.add("deleteIfFiltered");
+ props.add("batchSeparator");
props.add("messageDeduplicationIdStrategy");
props.add("kmsDataKeyReusePeriodSeconds");
props.add("visibilityTimeout");
diff --git
a/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
b/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
index b42cd00..4145479 100644
---
a/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
+++
b/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
@@ -45,6 +45,7 @@
"serverSideEncryptionEnabled": { "kind": "property", "displayName":
"Server Side Encryption Enabled", "group": "consumer", "label": "consumer",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": false,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "description": "Define if Server Side
Encryption is enabled or not on the queue" },
"visibilityTimeout": { "kind": "property", "displayName": "Visibility
Timeout", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "The duration (in seconds) that the received
messages are hidden from subsequent retrieve requests after [...]
"waitTimeSeconds": { "kind": "property", "displayName": "Wait Time
Seconds", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Duration in seconds (0 to 20) that the
ReceiveMessage action call will wait until a message is in the queu [...]
+ "batchSeparator": { "kind": "property", "displayName": "Batch Separator",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": ",", "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Set the separator when passing a String to
send batch message operation" },
"delaySeconds": { "kind": "property", "displayName": "Delay Seconds",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Delay sending messages for a number of
seconds." },
"lazyStartProducer": { "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 during star [...]
"messageDeduplicationIdStrategy": { "kind": "property", "displayName":
"Message Deduplication Id Strategy", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"useExchangeId", "useContentBasedDeduplication" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "useExchangeId",
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", [...]
@@ -93,6 +94,7 @@
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
"pollStrategy": { "kind": "parameter", "displayName": "Poll Strategy",
"group": "consumer (advanced)", "label": "consumer,advanced", "required":
false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation [...]
+ "batchSeparator": { "kind": "parameter", "displayName": "Batch Separator",
"group": "producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": ",", "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Set the separator when passing a String to
send batch message operation" },
"delaySeconds": { "kind": "parameter", "displayName": "Delay Seconds",
"group": "producer", "label": "producer", "required": false, "type": "integer",
"javaType": "java.lang.Integer", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Delay sending messages for a number of
seconds." },
"lazyStartProducer": { "kind": "parameter", "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 during sta [...]
"messageDeduplicationIdStrategy": { "kind": "parameter", "displayName":
"Message Deduplication Id Strategy", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"useExchangeId", "useContentBasedDeduplication" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "useExchangeId",
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration" [...]
diff --git a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
index 7d2a718..9a38a61 100644
--- a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
+++ b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
@@ -43,7 +43,7 @@ The queue will be created if they don't already exists. +
// component options: START
-The AWS 2 Simple Queue Service (SQS) component supports 40 options, which are
listed below.
+The AWS 2 Simple Queue Service (SQS) component supports 41 options, which are
listed below.
@@ -73,6 +73,7 @@ The AWS 2 Simple Queue Service (SQS) component supports 40
options, which are li
| *serverSideEncryptionEnabled* (consumer) | Define if Server Side Encryption
is enabled or not on the queue | false | boolean
| *visibilityTimeout* (consumer) | The duration (in seconds) that the received
messages are hidden from subsequent retrieve requests after being retrieved by
a ReceiveMessage request to set in the
com.amazonaws.services.sqs.model.SetQueueAttributesRequest. This only make
sense if its different from defaultVisibilityTimeout. It changes the queue
visibility timeout attribute permanently. | | Integer
| *waitTimeSeconds* (consumer) | Duration in seconds (0 to 20) that the
ReceiveMessage action call will wait until a message is in the queue to include
in the response. | | Integer
+| *batchSeparator* (producer) | Set the separator when passing a String to
send batch message operation | , | String
| *delaySeconds* (producer) | Delay sending messages for a number of seconds.
| | Integer
| *lazyStartProducer* (producer) | 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 during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
@@ -119,7 +120,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (58 parameters):
+=== Query Parameters (59 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -153,6 +154,7 @@ with the following path and query parameters:
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *pollStrategy* (consumer) | A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel.
| | PollingConsumerPollStrategy
+| *batchSeparator* (producer) | Set the separator when passing a String to
send batch message operation | , | String
| *delaySeconds* (producer) | Delay sending messages for a number of seconds.
| | Integer
| *lazyStartProducer* (producer) | 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 during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
diff --git
a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
index 58bda66..c9c8ed4 100644
---
a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
+++
b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
@@ -94,7 +94,7 @@ public class Sqs2Configuration implements Cloneable {
@UriParam(label = "producer")
private Sqs2Operations operation;
@UriParam(label = "producer", defaultValue = ",")
- private String batchSeparator;
+ private String batchSeparator = ",";
// queue properties
@UriParam(label = "queue")
@@ -573,23 +573,23 @@ public class Sqs2Configuration implements Cloneable {
public void setUseDefaultCredentialsProvider(boolean
useDefaultCredentialsProvider) {
this.useDefaultCredentialsProvider = useDefaultCredentialsProvider;
}
-
+
public String getBatchSeparator() {
- return batchSeparator;
- }
+ return batchSeparator;
+ }
/**
* Set the separator when passing a String to send batch message operation
*/
- public void setBatchSeparator(String batchSeparator) {
- this.batchSeparator = batchSeparator;
- }
+ public void setBatchSeparator(String batchSeparator) {
+ this.batchSeparator = batchSeparator;
+ }
// *************************************************
//
// *************************************************
- public Sqs2Configuration copy() {
+ public Sqs2Configuration copy() {
try {
return (Sqs2Configuration) super.clone();
} catch (CloneNotSupportedException e) {
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java
index d83549b..d3f6f33 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java
@@ -438,6 +438,23 @@ public interface Aws2SqsComponentBuilderFactory {
return this;
}
/**
+ * Set the separator when passing a String to send batch message
+ * operation.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ,
+ * Group: producer
+ *
+ * @param batchSeparator the value to set
+ * @return the dsl builder
+ */
+ default Aws2SqsComponentBuilder batchSeparator(
+ java.lang.String batchSeparator) {
+ doSetProperty("batchSeparator", batchSeparator);
+ return this;
+ }
+ /**
* Delay sending messages for a number of seconds.
*
* The option is a: <code>java.lang.Integer</code> type.
@@ -768,6 +785,7 @@ public interface Aws2SqsComponentBuilderFactory {
case "serverSideEncryptionEnabled":
getOrCreateConfiguration((Sqs2Component)
component).setServerSideEncryptionEnabled((boolean) value); return true;
case "visibilityTimeout": getOrCreateConfiguration((Sqs2Component)
component).setVisibilityTimeout((java.lang.Integer) value); return true;
case "waitTimeSeconds": getOrCreateConfiguration((Sqs2Component)
component).setWaitTimeSeconds((java.lang.Integer) value); return true;
+ case "batchSeparator": getOrCreateConfiguration((Sqs2Component)
component).setBatchSeparator((java.lang.String) value); return true;
case "delaySeconds": getOrCreateConfiguration((Sqs2Component)
component).setDelaySeconds((java.lang.Integer) value); return true;
case "lazyStartProducer": ((Sqs2Component)
component).setLazyStartProducer((boolean) value); return true;
case "messageDeduplicationIdStrategy":
getOrCreateConfiguration((Sqs2Component)
component).setMessageDeduplicationIdStrategy((java.lang.String) value); return
true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
index 0bf6317..1fa2f57 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
@@ -1918,6 +1918,22 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
+ * Set the separator when passing a String to send batch message
+ * operation.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: ,
+ * Group: producer
+ *
+ * @param batchSeparator the value to set
+ * @return the dsl builder
+ */
+ default Sqs2EndpointProducerBuilder batchSeparator(String
batchSeparator) {
+ doSetProperty("batchSeparator", batchSeparator);
+ return this;
+ }
+ /**
* Delay sending messages for a number of seconds.
*
* The option is a: <code>java.lang.Integer</code> type.
diff --git a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
index 917f487..d766b6f 100644
--- a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
@@ -45,7 +45,7 @@ The queue will be created if they don't already exists. +
// component options: START
-The AWS 2 Simple Queue Service (SQS) component supports 40 options, which are
listed below.
+The AWS 2 Simple Queue Service (SQS) component supports 41 options, which are
listed below.
@@ -75,6 +75,7 @@ The AWS 2 Simple Queue Service (SQS) component supports 40
options, which are li
| *serverSideEncryptionEnabled* (consumer) | Define if Server Side Encryption
is enabled or not on the queue | false | boolean
| *visibilityTimeout* (consumer) | The duration (in seconds) that the received
messages are hidden from subsequent retrieve requests after being retrieved by
a ReceiveMessage request to set in the
com.amazonaws.services.sqs.model.SetQueueAttributesRequest. This only make
sense if its different from defaultVisibilityTimeout. It changes the queue
visibility timeout attribute permanently. | | Integer
| *waitTimeSeconds* (consumer) | Duration in seconds (0 to 20) that the
ReceiveMessage action call will wait until a message is in the queue to include
in the response. | | Integer
+| *batchSeparator* (producer) | Set the separator when passing a String to
send batch message operation | , | String
| *delaySeconds* (producer) | Delay sending messages for a number of seconds.
| | Integer
| *lazyStartProducer* (producer) | 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 during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
@@ -121,7 +122,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (58 parameters):
+=== Query Parameters (59 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -155,6 +156,7 @@ with the following path and query parameters:
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *pollStrategy* (consumer) | A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the
poll operation before an Exchange have been created and being routed in Camel.
| | PollingConsumerPollStrategy
+| *batchSeparator* (producer) | Set the separator when passing a String to
send batch message operation | , | String
| *delaySeconds* (producer) | Delay sending messages for a number of seconds.
| | Integer
| *lazyStartProducer* (producer) | 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 during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
