You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2022/03/10 16:34:25 UTC
[camel] branch camel-3.14.x updated: Regen
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.14.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.14.x by this push:
new ef1ae78 Regen
ef1ae78 is described below
commit ef1ae78a6cad94836dfb8ce8d9cd39b6127c3889
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Mar 10 17:25:15 2022 +0100
Regen
---
camel-dependencies/pom.xml | 21 ++--
.../apache/camel/catalog/components/aws2-sqs.json | 10 +-
.../apache/camel/service/lra/LRASagaRoutes.java | 10 +-
.../dsl/Aws2SqsComponentBuilderFactory.java | 62 +++++++---
.../endpoint/dsl/Sqs2EndpointBuilderFactory.java | 137 ++++++++++++---------
5 files changed, 145 insertions(+), 95 deletions(-)
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index 590ee97..4ffda8d 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -17,7 +17,8 @@
limitations under the License.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache</groupId>
@@ -87,18 +88,18 @@
<c3p0-version>0.9.5.5</c3p0-version>
<caffeine-version>2.9.2</caffeine-version>
<californium-version>2.6.5</californium-version>
- <camel.osgi.activator />
- <camel.osgi.dynamic />
+ <camel.osgi.activator></camel.osgi.activator>
+ <camel.osgi.dynamic></camel.osgi.dynamic>
<camel.osgi.exclude.dependencies>false</camel.osgi.exclude.dependencies>
<camel.osgi.export>${camel.osgi.export.pkg};-noimport:=true;${camel.osgi.version}</camel.osgi.export>
<camel.osgi.export.pkg>$${replace;{local-packages};;;\;}</camel.osgi.export.pkg>
<camel.osgi.failok>false</camel.osgi.failok>
<camel.osgi.import>${camel.osgi.import.pkg}</camel.osgi.import>
- <camel.osgi.import.additional />
- <camel.osgi.import.before.defaults />
+ <camel.osgi.import.additional></camel.osgi.import.additional>
+ <camel.osgi.import.before.defaults></camel.osgi.import.before.defaults>
<camel.osgi.import.camel.version>version="[$(version;==;${camel.osgi.version.clean}),$(version;=+;${camel.osgi.version.clean}))"</camel.osgi.import.camel.version>
<camel.osgi.import.default.version>[$(version;==;$(@)),$(version;+;$(@)))</camel.osgi.import.default.version>
- <camel.osgi.import.defaults />
+ <camel.osgi.import.defaults></camel.osgi.import.defaults>
<camel.osgi.import.pkg>org.apache.camel.*;${camel.osgi.import.camel.version},
${camel.osgi.import.before.defaults},
${camel.osgi.import.defaults},
@@ -107,8 +108,8 @@
<camel.osgi.import.strict.version>version="[$(version;===;${camel.osgi.version.clean}),$(version;==+;${camel.osgi.version.clean}))"</camel.osgi.import.strict.version>
<camel.osgi.manifest>${project.build.outputDirectory}/META-INF/MANIFEST.MF</camel.osgi.manifest>
<camel.osgi.private.pkg>!*</camel.osgi.private.pkg>
- <camel.osgi.provide.capability />
- <camel.osgi.require.capability />
+ <camel.osgi.provide.capability></camel.osgi.provide.capability>
+ <camel.osgi.require.capability></camel.osgi.require.capability>
<camel.osgi.symbolic.name>${project.groupId}.${project.artifactId}</camel.osgi.symbolic.name>
<camel.osgi.version>version=${project.version}</camel.osgi.version>
<camel.surefire.fork.vmargs>-XX:+ExitOnOutOfMemoryError</camel.surefire.fork.vmargs>
@@ -162,9 +163,9 @@
<cxf-version-range>[3.4,3.4]</cxf-version-range>
<cxf-xjc-plugin-version>3.3.1</cxf-xjc-plugin-version>
<cxf-xjc-utils-version>3.3.1</cxf-xjc-utils-version>
- <cxf.codegen.jvmArgs />
+ <cxf.codegen.jvmArgs></cxf.codegen.jvmArgs>
<cxf.codegenplugin.forkmode>once</cxf.codegenplugin.forkmode>
- <cxf.xjc.jvmArgs />
+ <cxf.xjc.jvmArgs></cxf.xjc.jvmArgs>
<datasonnet-mapper-version>2.1.4</datasonnet-mapper-version>
<debezium-mysql-connector-version>8.0.27</debezium-mysql-connector-version>
<debezium-version>1.7.1.Final</debezium-version>
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sqs.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sqs.json
index f9d80db..125251f 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sqs.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/aws2-sqs.json
@@ -26,7 +26,7 @@
"amazonSQSClient": { "kind": "property", "displayName": "Amazon SQSClient", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.sqs.SqsClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To use the AmazonSQS as client" },
"autoCreateQueue": { "kind": "property", "displayName": "Auto Create Queue", "group": "common", "label": "", "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": "Setting the autocreation of the queue" },
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "deprecated": false, "autowired": false, "secret": false, "description": "The AWS SQS default configuration" },
- "overrideEndpoint": { "kind": "property", "displayName": "Override Endpoint", "group": "common", "label": "", "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": "Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpoint [...]
+ "overrideEndpoint": { "kind": "property", "displayName": "Override Endpoint", "group": "common", "label": "", "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": "Set the need for overriding the endpoint. This option needs to be used in combination with uriEndpoint [...]
"protocol": { "kind": "property", "displayName": "Protocol", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "https", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The underlying protocol used to communicate with SQS" },
"proxyProtocol": { "kind": "property", "displayName": "Proxy Protocol", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating the [...]
"queueOwnerAWSAccountId": { "kind": "property", "displayName": "Queue Owner AWSAccount Id", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Specify the queue owner aws account id when you need to connect the queue with different account owner." },
@@ -52,15 +52,16 @@
"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", [...]
"messageGroupIdStrategy": { "kind": "property", "displayName": "Message Group Id Strategy", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "useConstant", "useExchangeId", "usePropertyValue" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Only for FIFO queues. Strateg [...]
+ "messageHeaderExceededLimit": { "kind": "property", "displayName": "Message Header Exceeded Limit", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "WARN", "WARN_ONCE", "IGNORE", "FAIL" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "WARN", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "What to do [...]
"operation": { "kind": "property", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws2.sqs.Sqs2Operations", "enum": [ "sendBatchMessage", "deleteMessage", "listQueues", "purgeQueue", "deleteQueue" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description [...]
"autowiredEnabled": { "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 type, which t [...]
"delayQueue": { "kind": "property", "displayName": "Delay Queue", "group": "advanced", "label": "advanced", "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 you want to apply delaySeconds option to the queue or on single messages" },
- "queueUrl": { "kind": "property", "displayName": "Queue Url", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define the queueUrl explicitly. All other parameters, which would influence the queueUrl, are ignored. This parameter is [...]
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group": "proxy", "label": "proxy", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the SQS client" },
"proxyPort": { "kind": "property", "displayName": "Proxy Port", "group": "proxy", "label": "proxy", "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": "To define a proxy port when instantiating the SQS client" },
"maximumMessageSize": { "kind": "property", "displayName": "Maximum Message Size", "group": "queue", "label": "queue", "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 maximumMessageSize (in bytes) an SQS message can contain for this queue." },
"messageRetentionPeriod": { "kind": "property", "displayName": "Message Retention Period", "group": "queue", "label": "queue", "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 messageRetentionPeriod (in seconds) a message will be retained by SQS for this queue." },
"policy": { "kind": "property", "displayName": "Policy", "group": "queue", "label": "queue", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The policy for this queue. It can be loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load the [...]
+ "queueUrl": { "kind": "property", "displayName": "Queue Url", "group": "queue", "label": "queue", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define the queueUrl explicitly. All other parameters, which would influence the queueUrl, are ignored. This parameter is inten [...]
"receiveMessageWaitTimeSeconds": { "kind": "property", "displayName": "Receive Message Wait Time Seconds", "group": "queue", "label": "queue", "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": "If you do not specify WaitTimeSeconds in the request, the queue attribute ReceiveM [...]
"redrivePolicy": { "kind": "property", "displayName": "Redrive Policy", "group": "queue", "label": "queue", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Specify the policy that send message to DeadLetter queue. See detail at Amazon docs." },
"accessKey": { "kind": "property", "displayName": "Access Key", "group": "security", "label": "security", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Amazon AWS Access Key" },
@@ -72,7 +73,7 @@
"amazonSQSClient": { "kind": "parameter", "displayName": "Amazon SQSClient", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.sqs.SqsClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To use the AmazonSQS as client" },
"autoCreateQueue": { "kind": "parameter", "displayName": "Auto Create Queue", "group": "common", "label": "", "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": "Setting the autocreation of the queue" },
"headerFilterStrategy": { "kind": "parameter", "displayName": "Header Filter Strategy", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.spi.HeaderFilterStrategy", "deprecated": false, "autowired": false, "secret": false, "description": "To use a custom HeaderFilterStrategy to map headers to\/from Camel." },
- "overrideEndpoint": { "kind": "parameter", "displayName": "Override Endpoint", "group": "common", "label": "", "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": "Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpoin [...]
+ "overrideEndpoint": { "kind": "parameter", "displayName": "Override Endpoint", "group": "common", "label": "", "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": "Set the need for overriding the endpoint. This option needs to be used in combination with uriEndpoin [...]
"protocol": { "kind": "parameter", "displayName": "Protocol", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "https", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The underlying protocol used to communicate with SQS" },
"proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "HTTPS", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define a proxy protocol when instantiating th [...]
"queueOwnerAWSAccountId": { "kind": "parameter", "displayName": "Queue Owner AWSAccount Id", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": true, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Specify the queue owner aws account id when you need to connect the queue with different account owner." },
@@ -103,14 +104,15 @@
"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" [...]
"messageGroupIdStrategy": { "kind": "parameter", "displayName": "Message Group Id Strategy", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "useConstant", "useExchangeId", "usePropertyValue" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Only for FIFO queues. Strate [...]
+ "messageHeaderExceededLimit": { "kind": "parameter", "displayName": "Message Header Exceeded Limit", "group": "producer", "label": "producer", "required": false, "type": "string", "javaType": "java.lang.String", "enum": [ "WARN", "WARN_ONCE", "IGNORE", "FAIL" ], "deprecated": false, "autowired": false, "secret": false, "defaultValue": "WARN", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "What to d [...]
"operation": { "kind": "parameter", "displayName": "Operation", "group": "producer", "label": "producer", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws2.sqs.Sqs2Operations", "enum": [ "sendBatchMessage", "deleteMessage", "listQueues", "purgeQueue", "deleteQueue" ], "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "descriptio [...]
"delayQueue": { "kind": "parameter", "displayName": "Delay Queue", "group": "advanced", "label": "advanced", "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 you want to apply delaySeconds option to the queue or on single messages" },
- "queueUrl": { "kind": "parameter", "displayName": "Queue Url", "group": "advanced", "label": "advanced", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define the queueUrl explicitly. All other parameters, which would influence the queueUrl, are ignored. This parameter i [...]
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group": "proxy", "label": "proxy", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define a proxy host when instantiating the SQS client" },
"proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group": "proxy", "label": "proxy", "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": "To define a proxy port when instantiating the SQS client" },
"maximumMessageSize": { "kind": "parameter", "displayName": "Maximum Message Size", "group": "queue", "label": "queue", "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 maximumMessageSize (in bytes) an SQS message can contain for this queue." },
"messageRetentionPeriod": { "kind": "parameter", "displayName": "Message Retention Period", "group": "queue", "label": "queue", "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 messageRetentionPeriod (in seconds) a message will be retained by SQS for this queue." },
"policy": { "kind": "parameter", "displayName": "Policy", "group": "queue", "label": "queue", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The policy for this queue. It can be loaded by default from classpath, but you can prefix with classpath:, file:, or http: to load th [...]
+ "queueUrl": { "kind": "parameter", "displayName": "Queue Url", "group": "queue", "label": "queue", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To define the queueUrl explicitly. All other parameters, which would influence the queueUrl, are ignored. This parameter is inte [...]
"receiveMessageWaitTimeSeconds": { "kind": "parameter", "displayName": "Receive Message Wait Time Seconds", "group": "queue", "label": "queue", "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": "If you do not specify WaitTimeSeconds in the request, the queue attribute Receive [...]
"redrivePolicy": { "kind": "parameter", "displayName": "Redrive Policy", "group": "queue", "label": "queue", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Specify the policy that send message to DeadLetter queue. See detail at Amazon docs." },
"backoffErrorThreshold": { "kind": "parameter", "displayName": "Backoff Error Threshold", "group": "scheduler", "label": "consumer,scheduler", "required": false, "type": "integer", "javaType": "int", "deprecated": false, "autowired": false, "secret": false, "description": "The number of subsequent error polls (failed due some error) that should happen before the backoffMultipler should kick-in." },
diff --git a/components/camel-lra/src/main/java/org/apache/camel/service/lra/LRASagaRoutes.java b/components/camel-lra/src/main/java/org/apache/camel/service/lra/LRASagaRoutes.java
index 70bac76..c66ebcf 100644
--- a/components/camel-lra/src/main/java/org/apache/camel/service/lra/LRASagaRoutes.java
+++ b/components/camel-lra/src/main/java/org/apache/camel/service/lra/LRASagaRoutes.java
@@ -63,8 +63,7 @@ public class LRASagaRoutes extends RouteBuilder {
}
/**
- * Check if the request is pointing to an allowed URI to prevent unauthorized
- * remote uri invocation
+ * Check if the request is pointing to an allowed URI to prevent unauthorized remote uri invocation
*/
private void verifyRequest(Exchange exchange) {
if (exchange.getIn().getHeader(Exchange.SAGA_LONG_RUNNING_ACTION) == null) {
@@ -84,14 +83,15 @@ public class LRASagaRoutes extends RouteBuilder {
// CAMEL-17751: Extract URIs from the CamelHttpQuery header
if (usedURIs.isEmpty()) {
try {
- Map<String, Object> queryParams = URISupport.parseQuery(exchange.getIn().getHeader(Exchange.HTTP_QUERY, String.class));
+ Map<String, Object> queryParams
+ = URISupport.parseQuery(exchange.getIn().getHeader(Exchange.HTTP_QUERY, String.class));
if (!queryParams.isEmpty()) {
if (queryParams.get(URL_COMPENSATION_KEY) != null) {
compensationURI = queryParams.get(URL_COMPENSATION_KEY).toString();
usedURIs.add(compensationURI);
exchange.getIn().setHeader(URL_COMPENSATION_KEY, compensationURI);
}
-
+
if (queryParams.get(URL_COMPLETION_KEY) != null) {
completionURI = queryParams.get(URL_COMPLETION_KEY).toString();
usedURIs.add(completionURI);
@@ -99,7 +99,7 @@ public class LRASagaRoutes extends RouteBuilder {
}
}
} catch (URISyntaxException ex) {
- throw new RuntimeCamelException("URISyntaxException during " + Exchange.HTTP_QUERY + " header parsing");
+ throw new RuntimeCamelException("URISyntaxException during " + Exchange.HTTP_QUERY + " header parsing");
}
}
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 0d69af0..e93031f 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
@@ -113,7 +113,7 @@ public interface Aws2SqsComponentBuilderFactory {
return this;
}
/**
- * Set the need for overidding the endpoint. This option needs to be
+ * Set the need for overriding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
* The option is a: <code>boolean</code> type.
@@ -562,6 +562,29 @@ public interface Aws2SqsComponentBuilderFactory {
return this;
}
/**
+ * What to do if sending to AWS SQS has more messages than AWS allows
+ * (currently only maximum 10 message headers is allowed). WARN will log
+ * a WARN about the limit is for each additional header, so the message
+ * can be sent to AWS. WARN_ONCE will only log one time a WARN about the
+ * limit is hit, and drop additional headers, so the message can be sent
+ * to AWS. IGNORE will ignore (no logging) and drop additional headers,
+ * so the message can be sent to AWS. FAIL will cause an exception to be
+ * thrown and the message is not sent to AWS.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: WARN
+ * Group: producer
+ *
+ * @param messageHeaderExceededLimit the value to set
+ * @return the dsl builder
+ */
+ default Aws2SqsComponentBuilder messageHeaderExceededLimit(
+ java.lang.String messageHeaderExceededLimit) {
+ doSetProperty("messageHeaderExceededLimit", messageHeaderExceededLimit);
+ return this;
+ }
+ /**
* The operation to do in case the user don't want to send only a
* message.
*
@@ -616,23 +639,6 @@ public interface Aws2SqsComponentBuilderFactory {
return this;
}
/**
- * To define the queueUrl explicitly. All other parameters, which would
- * influence the queueUrl, are ignored. This parameter is intended to be
- * used, to connect to a mock implementation of SQS, for testing
- * purposes.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: advanced
- *
- * @param queueUrl the value to set
- * @return the dsl builder
- */
- default Aws2SqsComponentBuilder queueUrl(java.lang.String queueUrl) {
- doSetProperty("queueUrl", queueUrl);
- return this;
- }
- /**
* To define a proxy host when instantiating the SQS client.
*
* The option is a: <code>java.lang.String</code> type.
@@ -709,6 +715,23 @@ public interface Aws2SqsComponentBuilderFactory {
return this;
}
/**
+ * To define the queueUrl explicitly. All other parameters, which would
+ * influence the queueUrl, are ignored. This parameter is intended to be
+ * used, to connect to a mock implementation of SQS, for testing
+ * purposes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: queue
+ *
+ * @param queueUrl the value to set
+ * @return the dsl builder
+ */
+ default Aws2SqsComponentBuilder queueUrl(java.lang.String queueUrl) {
+ doSetProperty("queueUrl", queueUrl);
+ return this;
+ }
+ /**
* If you do not specify WaitTimeSeconds in the request, the queue
* attribute ReceiveMessageWaitTimeSeconds is used to determine how long
* to wait.
@@ -823,15 +846,16 @@ public interface Aws2SqsComponentBuilderFactory {
case "lazyStartProducer": ((Sqs2Component) component).setLazyStartProducer((boolean) value); return true;
case "messageDeduplicationIdStrategy": getOrCreateConfiguration((Sqs2Component) component).setMessageDeduplicationIdStrategy((java.lang.String) value); return true;
case "messageGroupIdStrategy": getOrCreateConfiguration((Sqs2Component) component).setMessageGroupIdStrategy((java.lang.String) value); return true;
+ case "messageHeaderExceededLimit": getOrCreateConfiguration((Sqs2Component) component).setMessageHeaderExceededLimit((java.lang.String) value); return true;
case "operation": getOrCreateConfiguration((Sqs2Component) component).setOperation((org.apache.camel.component.aws2.sqs.Sqs2Operations) value); return true;
case "autowiredEnabled": ((Sqs2Component) component).setAutowiredEnabled((boolean) value); return true;
case "delayQueue": getOrCreateConfiguration((Sqs2Component) component).setDelayQueue((boolean) value); return true;
- case "queueUrl": getOrCreateConfiguration((Sqs2Component) component).setQueueUrl((java.lang.String) value); return true;
case "proxyHost": getOrCreateConfiguration((Sqs2Component) component).setProxyHost((java.lang.String) value); return true;
case "proxyPort": getOrCreateConfiguration((Sqs2Component) component).setProxyPort((java.lang.Integer) value); return true;
case "maximumMessageSize": getOrCreateConfiguration((Sqs2Component) component).setMaximumMessageSize((java.lang.Integer) value); return true;
case "messageRetentionPeriod": getOrCreateConfiguration((Sqs2Component) component).setMessageRetentionPeriod((java.lang.Integer) value); return true;
case "policy": getOrCreateConfiguration((Sqs2Component) component).setPolicy((java.lang.String) value); return true;
+ case "queueUrl": getOrCreateConfiguration((Sqs2Component) component).setQueueUrl((java.lang.String) value); return true;
case "receiveMessageWaitTimeSeconds": getOrCreateConfiguration((Sqs2Component) component).setReceiveMessageWaitTimeSeconds((java.lang.Integer) value); return true;
case "redrivePolicy": getOrCreateConfiguration((Sqs2Component) component).setRedrivePolicy((java.lang.String) value); return true;
case "accessKey": getOrCreateConfiguration((Sqs2Component) component).setAccessKey((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 ea83596..70dd2cc 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
@@ -163,7 +163,7 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
- * Set the need for overidding the endpoint. This option needs to be
+ * Set the need for overriding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
* The option is a: <code>boolean</code> type.
@@ -180,7 +180,7 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
- * Set the need for overidding the endpoint. This option needs to be
+ * Set the need for overriding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
* The option will be converted to a <code>boolean</code>
@@ -967,6 +967,23 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
+ * To define the queueUrl explicitly. All other parameters, which would
+ * influence the queueUrl, are ignored. This parameter is intended to be
+ * used, to connect to a mock implementation of SQS, for testing
+ * purposes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: queue
+ *
+ * @param queueUrl the value to set
+ * @return the dsl builder
+ */
+ default Sqs2EndpointConsumerBuilder queueUrl(String queueUrl) {
+ doSetProperty("queueUrl", queueUrl);
+ return this;
+ }
+ /**
* If you do not specify WaitTimeSeconds in the request, the queue
* attribute ReceiveMessageWaitTimeSeconds is used to determine how long
* to wait.
@@ -1672,23 +1689,6 @@ public interface Sqs2EndpointBuilderFactory {
doSetProperty("delayQueue", delayQueue);
return this;
}
- /**
- * To define the queueUrl explicitly. All other parameters, which would
- * influence the queueUrl, are ignored. This parameter is intended to be
- * used, to connect to a mock implementation of SQS, for testing
- * purposes.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: advanced
- *
- * @param queueUrl the value to set
- * @return the dsl builder
- */
- default AdvancedSqs2EndpointConsumerBuilder queueUrl(String queueUrl) {
- doSetProperty("queueUrl", queueUrl);
- return this;
- }
}
/**
@@ -1816,7 +1816,7 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
- * Set the need for overidding the endpoint. This option needs to be
+ * Set the need for overriding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
* The option is a: <code>boolean</code> type.
@@ -1833,7 +1833,7 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
- * Set the need for overidding the endpoint. This option needs to be
+ * Set the need for overriding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
* The option will be converted to a <code>boolean</code>
@@ -2189,6 +2189,29 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
+ * What to do if sending to AWS SQS has more messages than AWS allows
+ * (currently only maximum 10 message headers is allowed). WARN will log
+ * a WARN about the limit is for each additional header, so the message
+ * can be sent to AWS. WARN_ONCE will only log one time a WARN about the
+ * limit is hit, and drop additional headers, so the message can be sent
+ * to AWS. IGNORE will ignore (no logging) and drop additional headers,
+ * so the message can be sent to AWS. FAIL will cause an exception to be
+ * thrown and the message is not sent to AWS.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Default: WARN
+ * Group: producer
+ *
+ * @param messageHeaderExceededLimit the value to set
+ * @return the dsl builder
+ */
+ default Sqs2EndpointProducerBuilder messageHeaderExceededLimit(
+ String messageHeaderExceededLimit) {
+ doSetProperty("messageHeaderExceededLimit", messageHeaderExceededLimit);
+ return this;
+ }
+ /**
* The operation to do in case the user don't want to send only a
* message.
*
@@ -2346,6 +2369,23 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
+ * To define the queueUrl explicitly. All other parameters, which would
+ * influence the queueUrl, are ignored. This parameter is intended to be
+ * used, to connect to a mock implementation of SQS, for testing
+ * purposes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: queue
+ *
+ * @param queueUrl the value to set
+ * @return the dsl builder
+ */
+ default Sqs2EndpointProducerBuilder queueUrl(String queueUrl) {
+ doSetProperty("queueUrl", queueUrl);
+ return this;
+ }
+ /**
* If you do not specify WaitTimeSeconds in the request, the queue
* attribute ReceiveMessageWaitTimeSeconds is used to determine how long
* to wait.
@@ -2469,23 +2509,6 @@ public interface Sqs2EndpointBuilderFactory {
doSetProperty("delayQueue", delayQueue);
return this;
}
- /**
- * To define the queueUrl explicitly. All other parameters, which would
- * influence the queueUrl, are ignored. This parameter is intended to be
- * used, to connect to a mock implementation of SQS, for testing
- * purposes.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: advanced
- *
- * @param queueUrl the value to set
- * @return the dsl builder
- */
- default AdvancedSqs2EndpointProducerBuilder queueUrl(String queueUrl) {
- doSetProperty("queueUrl", queueUrl);
- return this;
- }
}
/**
@@ -2609,7 +2632,7 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
- * Set the need for overidding the endpoint. This option needs to be
+ * Set the need for overriding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
* The option is a: <code>boolean</code> type.
@@ -2625,7 +2648,7 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
- * Set the need for overidding the endpoint. This option needs to be
+ * Set the need for overriding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
* The option will be converted to a <code>boolean</code>
@@ -2932,6 +2955,23 @@ public interface Sqs2EndpointBuilderFactory {
return this;
}
/**
+ * To define the queueUrl explicitly. All other parameters, which would
+ * influence the queueUrl, are ignored. This parameter is intended to be
+ * used, to connect to a mock implementation of SQS, for testing
+ * purposes.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: queue
+ *
+ * @param queueUrl the value to set
+ * @return the dsl builder
+ */
+ default Sqs2EndpointBuilder queueUrl(String queueUrl) {
+ doSetProperty("queueUrl", queueUrl);
+ return this;
+ }
+ /**
* If you do not specify WaitTimeSeconds in the request, the queue
* attribute ReceiveMessageWaitTimeSeconds is used to determine how long
* to wait.
@@ -3055,23 +3095,6 @@ public interface Sqs2EndpointBuilderFactory {
doSetProperty("delayQueue", delayQueue);
return this;
}
- /**
- * To define the queueUrl explicitly. All other parameters, which would
- * influence the queueUrl, are ignored. This parameter is intended to be
- * used, to connect to a mock implementation of SQS, for testing
- * purposes.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: advanced
- *
- * @param queueUrl the value to set
- * @return the dsl builder
- */
- default AdvancedSqs2EndpointBuilder queueUrl(String queueUrl) {
- doSetProperty("queueUrl", queueUrl);
- return this;
- }
}
/**