This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit b470ece4ca9cc110a9e31c99c2d79fd422f2bb9f Author: oscerd <[email protected]> AuthorDate: Tue Mar 8 11:14:16 2022 +0000 Regen for commit a3294eb324abf133f1bfa138658cc639bc78ae30 Signed-off-by: GitHub <[email protected]> --- .../apache/camel/catalog/components/aws2-sqs.json | 10 +- .../org/apache/camel/catalog/others.properties | 1 - .../org/apache/camel/catalog/others/console.json | 15 --- .../apache/camel/catalog/schemas/camel-spring.xsd | 8 ++ .../dsl/Aws2SqsComponentBuilderFactory.java | 62 +++++++--- .../endpoint/dsl/Sqs2EndpointBuilderFactory.java | 137 ++++++++++++--------- 6 files changed, 137 insertions(+), 96 deletions(-) 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 c0dae3b..fb5ae51 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/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others.properties b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others.properties index 5f99325..2ecc8b0 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others.properties +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others.properties @@ -8,7 +8,6 @@ cloud cloudevents cluster componentdsl -console csimple-joor cxf-transport debug diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others/console.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others/console.json deleted file mode 100644 index b1048bd..0000000 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/others/console.json +++ /dev/null @@ -1,15 +0,0 @@ -{ - "other": { - "kind": "other", - "name": "console", - "title": "Console", - "description": "Camel Developer Console", - "deprecated": false, - "firstVersion": "3.15.0", - "label": "core", - "supportLevel": "Preview", - "groupId": "org.apache.camel", - "artifactId": "camel-console", - "version": "3.16.0-SNAPSHOT" - } -} diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd index 6dd00d4..d06f7df 100644 --- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd +++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/schemas/camel-spring.xsd @@ -10612,6 +10612,14 @@ Reference to the route templates in the xml dsl. <xs:element maxOccurs="unbounded" minOccurs="0" ref="tns:onException"/> <xs:element maxOccurs="unbounded" minOccurs="0" ref="tns:onCompletion"/> </xs:sequence> + <xs:attribute name="precondition" type="xs:string"> + <xs:annotation> + <xs:documentation xml:lang="en"><![CDATA[ +The predicate of the precondition in simple language to evaluate in order to +determine if this route configuration should be included or not. + ]]></xs:documentation> + </xs:annotation> + </xs:attribute> </xs:extension> </xs:complexContent> </xs:complexType> diff --git a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java index 0d69af0..e93031f 100644 --- a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java +++ b/dsl/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/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java index b8f5b1e..7efd369 100644 --- a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java +++ b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java @@ -160,7 +160,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. @@ -177,7 +177,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> @@ -965,6 +965,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. @@ -1670,23 +1687,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; - } } /** @@ -1814,7 +1814,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. @@ -1831,7 +1831,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> @@ -2147,6 +2147,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. * @@ -2305,6 +2328,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. @@ -2428,23 +2468,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; - } } /** @@ -2569,7 +2592,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. @@ -2585,7 +2608,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> @@ -2893,6 +2916,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. @@ -3016,23 +3056,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; - } } public interface Sqs2Builders {
