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 <[email protected]>
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;
- }
}
/**
