This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new 0eda6209b52 Revert "Sqs duplicate (#14742)"
0eda6209b52 is described below
commit 0eda6209b52747e3276e249b54978694ea9caed7
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Jul 5 16:39:44 2024 +0200
Revert "Sqs duplicate (#14742)"
This reverts commit df3a9381251c9efa2bb7b2ad66a6fc7cb77dd175.
---
.../apache/camel/catalog/components/aws2-sqs.json | 83 +++++++++++-----------
.../component/aws2/sqs/Sqs2EndpointConfigurer.java | 6 --
.../component/aws2/sqs/Sqs2EndpointUriFactory.java | 3 +-
.../apache/camel/component/aws2/sqs/aws2-sqs.json | 83 +++++++++++-----------
.../camel/component/aws2/sqs/Sqs2Consumer.java | 45 ++----------
.../camel/component/aws2/sqs/Sqs2Endpoint.java | 25 -------
.../sqs/SqsBatchConsumerConcurrentConsumersIT.java | 4 +-
.../component/aws2/sqs/SqsBatchConsumerTest.java | 4 +-
.../SqsConsumerMessageLocalstackIT.java | 25 -------
.../endpoint/dsl/Sqs2EndpointBuilderFactory.java | 36 ----------
.../camel/kotlin/components/Aws2SqsUriDsl.kt | 9 ---
11 files changed, 93 insertions(+), 230 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 7b022445a8c..2b39c041cef 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
@@ -111,47 +111,46 @@
"bridgeErrorHandler": { "index": 23, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
"exceptionHandler": { "index": 24, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By de [...]
"exchangePattern": { "index": 25, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
- "inProgressRepository": { "index": 26, "kind": "parameter", "displayName":
"In Progress Repository", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.IdempotentRepository", "deprecated": false, "autowired":
false, "secret": false, "description": "A pluggable in-progress repository
org.apache.camel.spi.IdempotentRepository. The in-progress repository is used
to account the current in progress messages [...]
- "pollStrategy": { "index": 27, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
- "batchSeparator": { "index": 28, "kind": "parameter", "displayName":
"Batch Separator", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": ",", "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Set the separator when passing a String to
send batch message operation" },
- "delaySeconds": { "index": 29, "kind": "parameter", "displayName": "Delay
Seconds", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Delay sending messages for a number of
seconds." },
- "messageDeduplicationIdStrategy": { "index": 30, "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":
"c [...]
- "messageGroupIdStrategy": { "index": 31, "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 q [...]
- "messageHeaderExceededLimit": { "index": 32, "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 [...]
- "operation": { "index": 33, "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" [...]
- "lazyStartProducer": { "index": 34, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
- "amazonSQSClient": { "index": 35, "kind": "parameter", "displayName":
"Amazon SQSClient", "group": "advanced", "label": "advanced", "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
client" },
- "delayQueue": { "index": 36, "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" },
- "proxyHost": { "index": 37, "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": { "index": 38, "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" },
- "proxyProtocol": { "index": 39, "kind": "parameter", "displayName": "Proxy
Protocol", "group": "proxy", "label": "proxy", "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 [...]
- "maximumMessageSize": { "index": 40, "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": { "index": 41, "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 q [...]
- "policy": { "index": 42, "kind": "parameter", "displayName": "Policy",
"group": "queue", "label": "queue", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "supportFileReference": true,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "description": "The policy for this
queue. It can be loaded by default from classpa [...]
- "queueUrl": { "index": 43, "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 para [...]
- "receiveMessageWaitTimeSeconds": { "index": 44, "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 attr [...]
- "redrivePolicy": { "index": 45, "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": { "index": 46, "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." },
- "backoffIdleThreshold": { "index": 47, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
- "backoffMultiplier": { "index": 48, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
- "delay": { "index": 49, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
- "greedy": { "index": 50, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
- "initialDelay": { "index": 51, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
- "repeatCount": { "index": 52, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
- "runLoggingLevel": { "index": 53, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
- "scheduledExecutorService": { "index": 54, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
- "scheduler": { "index": 55, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
- "schedulerProperties": { "index": 56, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
- "startScheduler": { "index": 57, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
- "timeUnit": { "index": 58, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
- "useFixedDelay": { "index": 59, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." },
- "accessKey": { "index": 60, "kind": "parameter", "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" },
- "profileCredentialsName": { "index": 61, "kind": "parameter",
"displayName": "Profile Credentials Name", "group": "security", "label":
"security", "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": "If using a profile
credentials provider, this parameter will set the profile name" },
- "secretKey": { "index": 62, "kind": "parameter", "displayName": "Secret
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 Secret Key" },
- "sessionToken": { "index": 63, "kind": "parameter", "displayName":
"Session Token", "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 Session Token used when the user
needs to assume an IAM role" },
- "trustAllCertificates": { "index": 64, "kind": "parameter", "displayName":
"Trust All Certificates", "group": "security", "label": "security", "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": "If we want to trust all
certificates in case of overriding the endpoint" },
- "useDefaultCredentialsProvider": { "index": 65, "kind": "parameter",
"displayName": "Use Default Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
- "useProfileCredentialsProvider": { "index": 66, "kind": "parameter",
"displayName": "Use Profile Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
- "useSessionCredentials": { "index": 67, "kind": "parameter",
"displayName": "Use Session Credentials", "group": "security", "label":
"security", "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 whether the SQS client should expect to
use Session Credentials [...]
+ "pollStrategy": { "index": 26, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
+ "batchSeparator": { "index": 27, "kind": "parameter", "displayName":
"Batch Separator", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": ",", "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Set the separator when passing a String to
send batch message operation" },
+ "delaySeconds": { "index": 28, "kind": "parameter", "displayName": "Delay
Seconds", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Delay sending messages for a number of
seconds." },
+ "messageDeduplicationIdStrategy": { "index": 29, "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":
"c [...]
+ "messageGroupIdStrategy": { "index": 30, "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 q [...]
+ "messageHeaderExceededLimit": { "index": 31, "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 [...]
+ "operation": { "index": 32, "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" [...]
+ "lazyStartProducer": { "index": 33, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "amazonSQSClient": { "index": 34, "kind": "parameter", "displayName":
"Amazon SQSClient", "group": "advanced", "label": "advanced", "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
client" },
+ "delayQueue": { "index": 35, "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" },
+ "proxyHost": { "index": 36, "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": { "index": 37, "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" },
+ "proxyProtocol": { "index": 38, "kind": "parameter", "displayName": "Proxy
Protocol", "group": "proxy", "label": "proxy", "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 [...]
+ "maximumMessageSize": { "index": 39, "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": { "index": 40, "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 q [...]
+ "policy": { "index": 41, "kind": "parameter", "displayName": "Policy",
"group": "queue", "label": "queue", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "supportFileReference": true,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "description": "The policy for this
queue. It can be loaded by default from classpa [...]
+ "queueUrl": { "index": 42, "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 para [...]
+ "receiveMessageWaitTimeSeconds": { "index": 43, "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 attr [...]
+ "redrivePolicy": { "index": 44, "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": { "index": 45, "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." },
+ "backoffIdleThreshold": { "index": 46, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
+ "backoffMultiplier": { "index": 47, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
+ "delay": { "index": 48, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
+ "greedy": { "index": 49, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
+ "initialDelay": { "index": 50, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
+ "repeatCount": { "index": 51, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
+ "runLoggingLevel": { "index": 52, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
+ "scheduledExecutorService": { "index": 53, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
+ "scheduler": { "index": 54, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
+ "schedulerProperties": { "index": 55, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
+ "startScheduler": { "index": 56, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
+ "timeUnit": { "index": 57, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
+ "useFixedDelay": { "index": 58, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." },
+ "accessKey": { "index": 59, "kind": "parameter", "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" },
+ "profileCredentialsName": { "index": 60, "kind": "parameter",
"displayName": "Profile Credentials Name", "group": "security", "label":
"security", "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": "If using a profile
credentials provider, this parameter will set the profile name" },
+ "secretKey": { "index": 61, "kind": "parameter", "displayName": "Secret
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 Secret Key" },
+ "sessionToken": { "index": 62, "kind": "parameter", "displayName":
"Session Token", "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 Session Token used when the user
needs to assume an IAM role" },
+ "trustAllCertificates": { "index": 63, "kind": "parameter", "displayName":
"Trust All Certificates", "group": "security", "label": "security", "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": "If we want to trust all
certificates in case of overriding the endpoint" },
+ "useDefaultCredentialsProvider": { "index": 64, "kind": "parameter",
"displayName": "Use Default Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
+ "useProfileCredentialsProvider": { "index": 65, "kind": "parameter",
"displayName": "Use Profile Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
+ "useSessionCredentials": { "index": 66, "kind": "parameter",
"displayName": "Use Session Credentials", "group": "security", "label":
"security", "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 whether the SQS client should expect to
use Session Credentials [...]
}
}
diff --git
a/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
b/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
index e0c70105a2e..ec77700c14e 100644
---
a/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
+++
b/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointConfigurer.java
@@ -65,8 +65,6 @@ public class Sqs2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "greedy": target.setGreedy(property(camelContext, boolean.class,
value)); return true;
case "headerfilterstrategy":
case "headerFilterStrategy":
target.setHeaderFilterStrategy(property(camelContext,
org.apache.camel.spi.HeaderFilterStrategy.class, value)); return true;
- case "inprogressrepository":
- case "inProgressRepository":
target.setInProgressRepository(property(camelContext,
org.apache.camel.spi.IdempotentRepository.class, value)); return true;
case "initialdelay":
case "initialDelay": target.setInitialDelay(property(camelContext,
long.class, value)); return true;
case "kmsdatakeyreuseperiodseconds":
@@ -204,8 +202,6 @@ public class Sqs2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "greedy": return boolean.class;
case "headerfilterstrategy":
case "headerFilterStrategy": return
org.apache.camel.spi.HeaderFilterStrategy.class;
- case "inprogressrepository":
- case "inProgressRepository": return
org.apache.camel.spi.IdempotentRepository.class;
case "initialdelay":
case "initialDelay": return long.class;
case "kmsdatakeyreuseperiodseconds":
@@ -339,8 +335,6 @@ public class Sqs2EndpointConfigurer extends
PropertyConfigurerSupport implements
case "greedy": return target.isGreedy();
case "headerfilterstrategy":
case "headerFilterStrategy": return target.getHeaderFilterStrategy();
- case "inprogressrepository":
- case "inProgressRepository": return target.getInProgressRepository();
case "initialdelay":
case "initialDelay": return target.getInitialDelay();
case "kmsdatakeyreuseperiodseconds":
diff --git
a/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
b/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
index 895aa292b1f..7c160dde740 100644
---
a/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
+++
b/components/camel-aws/camel-aws2-sqs/src/generated/java/org/apache/camel/component/aws2/sqs/Sqs2EndpointUriFactory.java
@@ -23,7 +23,7 @@ public class Sqs2EndpointUriFactory extends
org.apache.camel.support.component.E
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(68);
+ Set<String> props = new HashSet<>(67);
props.add("accessKey");
props.add("amazonAWSHost");
props.add("amazonSQSClient");
@@ -46,7 +46,6 @@ public class Sqs2EndpointUriFactory extends
org.apache.camel.support.component.E
props.add("extendMessageVisibility");
props.add("greedy");
props.add("headerFilterStrategy");
- props.add("inProgressRepository");
props.add("initialDelay");
props.add("kmsDataKeyReusePeriodSeconds");
props.add("kmsMasterKeyId");
diff --git
a/components/camel-aws/camel-aws2-sqs/src/generated/resources/META-INF/org/apache/camel/component/aws2/sqs/aws2-sqs.json
b/components/camel-aws/camel-aws2-sqs/src/generated/resources/META-INF/org/apache/camel/component/aws2/sqs/aws2-sqs.json
index 7b022445a8c..2b39c041cef 100644
---
a/components/camel-aws/camel-aws2-sqs/src/generated/resources/META-INF/org/apache/camel/component/aws2/sqs/aws2-sqs.json
+++
b/components/camel-aws/camel-aws2-sqs/src/generated/resources/META-INF/org/apache/camel/component/aws2/sqs/aws2-sqs.json
@@ -111,47 +111,46 @@
"bridgeErrorHandler": { "index": 23, "kind": "parameter", "displayName":
"Bridge Error Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions (if possible) occurred
while the Camel consumer is trying to pickup incoming [...]
"exceptionHandler": { "index": 24, "kind": "parameter", "displayName":
"Exception Handler", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By de [...]
"exchangePattern": { "index": 25, "kind": "parameter", "displayName":
"Exchange Pattern", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut" ],
"deprecated": false, "autowired": false, "secret": false, "description": "Sets
the exchange pattern when the consumer creates an exchange." },
- "inProgressRepository": { "index": 26, "kind": "parameter", "displayName":
"In Progress Repository", "group": "consumer (advanced)", "label":
"consumer,advanced", "required": false, "type": "object", "javaType":
"org.apache.camel.spi.IdempotentRepository", "deprecated": false, "autowired":
false, "secret": false, "description": "A pluggable in-progress repository
org.apache.camel.spi.IdempotentRepository. The in-progress repository is used
to account the current in progress messages [...]
- "pollStrategy": { "index": 27, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
- "batchSeparator": { "index": 28, "kind": "parameter", "displayName":
"Batch Separator", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": ",", "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Set the separator when passing a String to
send batch message operation" },
- "delaySeconds": { "index": 29, "kind": "parameter", "displayName": "Delay
Seconds", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Delay sending messages for a number of
seconds." },
- "messageDeduplicationIdStrategy": { "index": 30, "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":
"c [...]
- "messageGroupIdStrategy": { "index": 31, "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 q [...]
- "messageHeaderExceededLimit": { "index": 32, "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 [...]
- "operation": { "index": 33, "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" [...]
- "lazyStartProducer": { "index": 34, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
- "amazonSQSClient": { "index": 35, "kind": "parameter", "displayName":
"Amazon SQSClient", "group": "advanced", "label": "advanced", "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
client" },
- "delayQueue": { "index": 36, "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" },
- "proxyHost": { "index": 37, "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": { "index": 38, "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" },
- "proxyProtocol": { "index": 39, "kind": "parameter", "displayName": "Proxy
Protocol", "group": "proxy", "label": "proxy", "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 [...]
- "maximumMessageSize": { "index": 40, "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": { "index": 41, "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 q [...]
- "policy": { "index": 42, "kind": "parameter", "displayName": "Policy",
"group": "queue", "label": "queue", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "supportFileReference": true,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "description": "The policy for this
queue. It can be loaded by default from classpa [...]
- "queueUrl": { "index": 43, "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 para [...]
- "receiveMessageWaitTimeSeconds": { "index": 44, "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 attr [...]
- "redrivePolicy": { "index": 45, "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": { "index": 46, "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." },
- "backoffIdleThreshold": { "index": 47, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
- "backoffMultiplier": { "index": 48, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
- "delay": { "index": 49, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
- "greedy": { "index": 50, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
- "initialDelay": { "index": 51, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
- "repeatCount": { "index": 52, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
- "runLoggingLevel": { "index": 53, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
- "scheduledExecutorService": { "index": 54, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
- "scheduler": { "index": 55, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
- "schedulerProperties": { "index": 56, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
- "startScheduler": { "index": 57, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
- "timeUnit": { "index": 58, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
- "useFixedDelay": { "index": 59, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." },
- "accessKey": { "index": 60, "kind": "parameter", "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" },
- "profileCredentialsName": { "index": 61, "kind": "parameter",
"displayName": "Profile Credentials Name", "group": "security", "label":
"security", "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": "If using a profile
credentials provider, this parameter will set the profile name" },
- "secretKey": { "index": 62, "kind": "parameter", "displayName": "Secret
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 Secret Key" },
- "sessionToken": { "index": 63, "kind": "parameter", "displayName":
"Session Token", "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 Session Token used when the user
needs to assume an IAM role" },
- "trustAllCertificates": { "index": 64, "kind": "parameter", "displayName":
"Trust All Certificates", "group": "security", "label": "security", "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": "If we want to trust all
certificates in case of overriding the endpoint" },
- "useDefaultCredentialsProvider": { "index": 65, "kind": "parameter",
"displayName": "Use Default Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
- "useProfileCredentialsProvider": { "index": 66, "kind": "parameter",
"displayName": "Use Profile Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
- "useSessionCredentials": { "index": 67, "kind": "parameter",
"displayName": "Use Session Credentials", "group": "security", "label":
"security", "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 whether the SQS client should expect to
use Session Credentials [...]
+ "pollStrategy": { "index": 26, "kind": "parameter", "displayName": "Poll
Strategy", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.PollingConsumerPollStrategy", "deprecated": false,
"autowired": false, "secret": false, "description": "A pluggable
org.apache.camel.PollingConsumerPollingStrategy allowing you to provide your
custom implementation to control error handling usually occurred during the po
[...]
+ "batchSeparator": { "index": 27, "kind": "parameter", "displayName":
"Batch Separator", "group": "producer", "label": "producer", "required": false,
"type": "string", "javaType": "java.lang.String", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": ",", "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Set the separator when passing a String to
send batch message operation" },
+ "delaySeconds": { "index": 28, "kind": "parameter", "displayName": "Delay
Seconds", "group": "producer", "label": "producer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Delay sending messages for a number of
seconds." },
+ "messageDeduplicationIdStrategy": { "index": 29, "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":
"c [...]
+ "messageGroupIdStrategy": { "index": 30, "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 q [...]
+ "messageHeaderExceededLimit": { "index": 31, "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 [...]
+ "operation": { "index": 32, "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" [...]
+ "lazyStartProducer": { "index": 33, "kind": "parameter", "displayName":
"Lazy Start Producer", "group": "producer (advanced)", "label":
"producer,advanced", "required": false, "type": "boolean", "javaType":
"boolean", "deprecated": false, "autowired": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a produ [...]
+ "amazonSQSClient": { "index": 34, "kind": "parameter", "displayName":
"Amazon SQSClient", "group": "advanced", "label": "advanced", "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
client" },
+ "delayQueue": { "index": 35, "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" },
+ "proxyHost": { "index": 36, "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": { "index": 37, "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" },
+ "proxyProtocol": { "index": 38, "kind": "parameter", "displayName": "Proxy
Protocol", "group": "proxy", "label": "proxy", "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 [...]
+ "maximumMessageSize": { "index": 39, "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": { "index": 40, "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 q [...]
+ "policy": { "index": 41, "kind": "parameter", "displayName": "Policy",
"group": "queue", "label": "queue", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "supportFileReference": true,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "description": "The policy for this
queue. It can be loaded by default from classpa [...]
+ "queueUrl": { "index": 42, "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 para [...]
+ "receiveMessageWaitTimeSeconds": { "index": 43, "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 attr [...]
+ "redrivePolicy": { "index": 44, "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": { "index": 45, "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." },
+ "backoffIdleThreshold": { "index": 46, "kind": "parameter", "displayName":
"Backoff Idle Threshold", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "The number of subsequent
idle polls that should happen before the backoffMultipler should kick-in." },
+ "backoffMultiplier": { "index": 47, "kind": "parameter", "displayName":
"Backoff Multiplier", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "int", "deprecated": false,
"autowired": false, "secret": false, "description": "To let the scheduled
polling consumer backoff if there has been a number of subsequent idles\/errors
in a row. The multiplier is then the number of polls that will be skipped
before the next actual attempt is h [...]
+ "delay": { "index": 48, "kind": "parameter", "displayName": "Delay",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 500, "description": "Milliseconds before the
next poll." },
+ "greedy": { "index": 49, "kind": "parameter", "displayName": "Greedy",
"group": "scheduler", "label": "consumer,scheduler", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "If greedy is enabled,
then the ScheduledPollConsumer will run immediately again, if the previous run
polled 1 or more messages." },
+ "initialDelay": { "index": 50, "kind": "parameter", "displayName":
"Initial Delay", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "integer", "javaType": "long", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": 1000, "description":
"Milliseconds before the first poll starts." },
+ "repeatCount": { "index": 51, "kind": "parameter", "displayName": "Repeat
Count", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "integer", "javaType": "long", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 0, "description": "Specifies a maximum limit
of number of fires. So if you set it to 1, the scheduler will only fire once.
If you set it to 5, it will only fire five times. A value of zero or negative
means fire forever." },
+ "runLoggingLevel": { "index": 52, "kind": "parameter", "displayName": "Run
Logging Level", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"org.apache.camel.LoggingLevel", "enum": [ "TRACE", "DEBUG", "INFO", "WARN",
"ERROR", "OFF" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "TRACE", "description": "The consumer logs a start\/complete
log line when it polls. This option allows you to configure the l [...]
+ "scheduledExecutorService": { "index": 53, "kind": "parameter",
"displayName": "Scheduled Executor Service", "group": "scheduler", "label":
"consumer,scheduler", "required": false, "type": "object", "javaType":
"java.util.concurrent.ScheduledExecutorService", "deprecated": false,
"autowired": false, "secret": false, "description": "Allows for configuring a
custom\/shared thread pool to use for the consumer. By default each consumer
has its own single threaded thread pool." },
+ "scheduler": { "index": 54, "kind": "parameter", "displayName":
"Scheduler", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "object", "javaType": "java.lang.Object", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "none", "description": "To
use a cron scheduler from either camel-spring or camel-quartz component. Use
value spring or quartz for built in scheduler" },
+ "schedulerProperties": { "index": 55, "kind": "parameter", "displayName":
"Scheduler Properties", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "object", "javaType":
"java.util.Map<java.lang.String, java.lang.Object>", "prefix": "scheduler.",
"multiValue": true, "deprecated": false, "autowired": false, "secret": false,
"description": "To configure additional properties when using a custom
scheduler or any of the Quartz, Spring based scheduler." },
+ "startScheduler": { "index": 56, "kind": "parameter", "displayName":
"Start Scheduler", "group": "scheduler", "label": "consumer,scheduler",
"required": false, "type": "boolean", "javaType": "boolean", "deprecated":
false, "autowired": false, "secret": false, "defaultValue": true,
"description": "Whether the scheduler should be auto started." },
+ "timeUnit": { "index": 57, "kind": "parameter", "displayName": "Time
Unit", "group": "scheduler", "label": "consumer,scheduler", "required": false,
"type": "object", "javaType": "java.util.concurrent.TimeUnit", "enum": [
"NANOSECONDS", "MICROSECONDS", "MILLISECONDS", "SECONDS", "MINUTES", "HOURS",
"DAYS" ], "deprecated": false, "autowired": false, "secret": false,
"defaultValue": "MILLISECONDS", "description": "Time unit for initialDelay and
delay options." },
+ "useFixedDelay": { "index": 58, "kind": "parameter", "displayName": "Use
Fixed Delay", "group": "scheduler", "label": "consumer,scheduler", "required":
false, "type": "boolean", "javaType": "boolean", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": true, "description":
"Controls if fixed delay or fixed rate is used. See ScheduledExecutorService in
JDK for details." },
+ "accessKey": { "index": 59, "kind": "parameter", "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" },
+ "profileCredentialsName": { "index": 60, "kind": "parameter",
"displayName": "Profile Credentials Name", "group": "security", "label":
"security", "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": "If using a profile
credentials provider, this parameter will set the profile name" },
+ "secretKey": { "index": 61, "kind": "parameter", "displayName": "Secret
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 Secret Key" },
+ "sessionToken": { "index": 62, "kind": "parameter", "displayName":
"Session Token", "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 Session Token used when the user
needs to assume an IAM role" },
+ "trustAllCertificates": { "index": 63, "kind": "parameter", "displayName":
"Trust All Certificates", "group": "security", "label": "security", "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": "If we want to trust all
certificates in case of overriding the endpoint" },
+ "useDefaultCredentialsProvider": { "index": 64, "kind": "parameter",
"displayName": "Use Default Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
+ "useProfileCredentialsProvider": { "index": 65, "kind": "parameter",
"displayName": "Use Profile Credentials Provider", "group": "security",
"label": "security", "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 whether the SQS client should expect to
load c [...]
+ "useSessionCredentials": { "index": 66, "kind": "parameter",
"displayName": "Use Session Credentials", "group": "security", "label":
"security", "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 whether the SQS client should expect to
use Session Credentials [...]
}
}
diff --git
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
index 25d76b66170..1ff99a1a63f 100644
---
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
+++
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Consumer.java
@@ -156,28 +156,9 @@ public class Sqs2Consumer extends
ScheduledBatchPollingConsumer {
}
Queue<Exchange> answer = new LinkedList<>();
- try {
- for (software.amazon.awssdk.services.sqs.model.Message message :
messages) {
- String key = message.messageId();
- // check if sqs is already in progress (add false = duplicate
message)
- if (!getEndpoint().getInProgressRepository().add(key)) {
- if (LOG.isTraceEnabled()) {
- LOG.trace("Skipping as sqs message is already in
progress: {}", key);
- }
- continue;
- }
- Exchange exchange = createExchange(message);
- answer.add(exchange);
- }
- } catch (Exception e) {
- // remove all in-progress as we failed
- for (Exchange exchange : answer) {
- String key = exchange.getProperty(Sqs2Constants.MESSAGE_ID,
String.class);
- if (key != null) {
- getEndpoint().getInProgressRepository().remove(key);
- }
- }
- throw e;
+ for (software.amazon.awssdk.services.sqs.model.Message message :
messages) {
+ Exchange exchange = createExchange(message);
+ answer.add(exchange);
}
return answer;
@@ -206,26 +187,12 @@ public class Sqs2Consumer extends
ScheduledBatchPollingConsumer {
exchange.getExchangeExtension().addOnCompletion(new
Synchronization() {
@Override
public void onComplete(Exchange exchange) {
- final String key =
exchange.getProperty(Sqs2Constants.MESSAGE_ID, String.class);
- try {
- processCommit(exchange);
- } finally {
- if (key != null) {
-
getEndpoint().getInProgressRepository().remove(key);
- }
- }
+ processCommit(exchange);
}
@Override
public void onFailure(Exchange exchange) {
- final String key =
exchange.getProperty(Sqs2Constants.MESSAGE_ID, String.class);
- try {
- processRollback(exchange);
- } finally {
- if (key != null) {
-
getEndpoint().getInProgressRepository().remove(key);
- }
- }
+ processRollback(exchange);
}
@Override
@@ -249,6 +216,7 @@ public class Sqs2Consumer extends
ScheduledBatchPollingConsumer {
*/
protected void processCommit(Exchange exchange) {
try {
+
if (shouldDelete(exchange)) {
String receiptHandle =
exchange.getIn().getHeader(Sqs2Constants.RECEIPT_HANDLE, String.class);
DeleteMessageRequest.Builder deleteRequest
@@ -317,7 +285,6 @@ public class Sqs2Consumer extends
ScheduledBatchPollingConsumer {
Message message = exchange.getIn();
message.setBody(msg.body());
message.setHeaders(new HashMap<>(msg.attributesAsStrings()));
- message.getExchange().setProperty(Sqs2Constants.MESSAGE_ID,
msg.messageId());
message.setHeader(Sqs2Constants.MESSAGE_ID, msg.messageId());
message.setHeader(Sqs2Constants.MD5_OF_BODY, msg.md5OfBody());
message.setHeader(Sqs2Constants.RECEIPT_HANDLE, msg.receiptHandle());
diff --git
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
index 288b1a5a9cd..d253848dcd6 100644
---
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
+++
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java
@@ -31,8 +31,6 @@ import
org.apache.camel.component.aws2.sqs.client.Sqs2ClientFactory;
import org.apache.camel.spi.*;
import org.apache.camel.support.ResourceHelper;
import org.apache.camel.support.ScheduledPollEndpoint;
-import
org.apache.camel.support.processor.idempotent.MemoryIdempotentRepository;
-import org.apache.camel.support.service.ServiceHelper;
import org.apache.camel.util.FileUtil;
import org.apache.camel.util.ObjectHelper;
import org.apache.commons.io.IOUtils;
@@ -60,7 +58,6 @@ import software.amazon.awssdk.services.sqs.model.SqsException;
public class Sqs2Endpoint extends ScheduledPollEndpoint implements
HeaderFilterStrategyAware, EndpointServiceLocation {
private static final Logger LOG =
LoggerFactory.getLogger(Sqs2Endpoint.class);
- private static final int DEFAULT_IN_PROGRESS_CACHE_SIZE = 10000;
private SqsClient client;
private String queueUrl;
@@ -73,11 +70,6 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint
implements HeaderFilterS
private Sqs2Configuration configuration;
@UriParam(label = "consumer")
private int maxMessagesPerPoll;
- @UriParam(label = "consumer,advanced", description = "A pluggable
in-progress repository "
- +
"org.apache.camel.spi.IdempotentRepository. The in-progress repository is used
to account the current in "
- + "progress messages
being consumed. By default a memory based repository is used.")
- private IdempotentRepository inProgressRepository
- =
MemoryIdempotentRepository.memoryIdempotentRepository(DEFAULT_IN_PROGRESS_CACHE_SIZE);
@UriParam
private HeaderFilterStrategy headerFilterStrategy;
@@ -150,7 +142,6 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint
implements HeaderFilterS
@Override
protected void doInit() throws Exception {
super.doInit();
- ServiceHelper.initService(inProgressRepository);
client = configuration.getAmazonSQSClient() != null
? configuration.getAmazonSQSClient() :
Sqs2ClientFactory.getSqsClient(configuration).getSQSClient();
@@ -190,13 +181,6 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint
implements HeaderFilterS
LOG.debug("Using Amazon SQS queue url: {}", queueUrl);
updateQueueAttributes(client);
}
- ServiceHelper.initService(inProgressRepository);
- }
-
- @Override
- protected void doStart() throws Exception {
- super.doStart();
- ServiceHelper.startService(inProgressRepository);
}
private void initQueueUrl() {
@@ -373,7 +357,6 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint
implements HeaderFilterS
client.close();
}
}
- ServiceHelper.stopService(inProgressRepository);
super.doStop();
}
@@ -418,14 +401,6 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint
implements HeaderFilterS
this.maxMessagesPerPoll = maxMessagesPerPoll;
}
- public IdempotentRepository getInProgressRepository() {
- return inProgressRepository;
- }
-
- public void setInProgressRepository(IdempotentRepository
inProgressRepository) {
- this.inProgressRepository = inProgressRepository;
- }
-
@Override
public String getServiceUrl() {
if (!configuration.isOverrideEndpoint()) {
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java
index 5af1fcf22f7..ab5b308a46a 100644
---
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerConcurrentConsumersIT.java
@@ -43,8 +43,8 @@ public class SqsBatchConsumerConcurrentConsumersIT extends
CamelTestSupport {
for (int counter = 0; counter < 6; counter++) {
Message.Builder message = Message.builder();
message.body("Message " + counter);
- message.md5OfBody("6a1559560f67c5e7a7d5d838bf0272ee-" + counter);
- message.messageId("f6fb6f99-5eb2-4be4-9b15-144774141458-" +
counter);
+ message.md5OfBody("6a1559560f67c5e7a7d5d838bf0272ee");
+ message.messageId("f6fb6f99-5eb2-4be4-9b15-144774141458");
message.receiptHandle("0NNAq8PwvXsyZkR6yu4nQ07FGxNmOBWi5");
clientMock.messages.add(message.build());
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerTest.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerTest.java
index d09fa4ec963..f2a476f3179 100644
---
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerTest.java
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsBatchConsumerTest.java
@@ -57,8 +57,8 @@ public class SqsBatchConsumerTest extends CamelTestSupport {
for (int counter = 0; counter < 6; counter++) {
Message.Builder message = Message.builder();
message.body("Message " + counter);
- message.md5OfBody("6a1559560f67c5e7a7d5d838bf0272ee-" + counter);
- message.messageId("f6fb6f99-5eb2-4be4-9b15-144774141458-" +
counter);
+ message.md5OfBody("6a1559560f67c5e7a7d5d838bf0272ee");
+ message.messageId("f6fb6f99-5eb2-4be4-9b15-144774141458");
message.receiptHandle("0NNAq8PwvXsyZkR6yu4nQ07FGxNmOBWi5");
clientMock.messages.add(message.build());
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageLocalstackIT.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageLocalstackIT.java
index 33f3c653e4b..3ee520d9ead 100644
---
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageLocalstackIT.java
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageLocalstackIT.java
@@ -16,21 +16,14 @@
*/
package org.apache.camel.component.aws2.sqs.integration;
-import java.util.concurrent.TimeUnit;
-
import org.apache.camel.EndpointInject;
import org.apache.camel.Exchange;
import org.apache.camel.ExchangePattern;
import org.apache.camel.Processor;
import org.apache.camel.ProducerTemplate;
import org.apache.camel.builder.RouteBuilder;
-import org.apache.camel.component.aws2.sqs.Sqs2Constants;
-import org.apache.camel.component.aws2.sqs.Sqs2Endpoint;
import org.apache.camel.component.mock.MockEndpoint;
-import
org.apache.camel.support.processor.idempotent.MemoryIdempotentRepository;
-import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.Test;
-import org.testcontainers.shaded.org.awaitility.Awaitility;
public class SqsConsumerMessageLocalstackIT extends Aws2SQSBaseTest {
@@ -57,15 +50,6 @@ public class SqsConsumerMessageLocalstackIT extends
Aws2SQSBaseTest {
});
MockEndpoint.assertIsSatisfied(context);
-
- Sqs2Endpoint sqs = (Sqs2Endpoint)
context.getRoute("sqsConsumer").getEndpoint();
- MemoryIdempotentRepository repo = (MemoryIdempotentRepository)
sqs.getInProgressRepository();
-
- // in-progress should remove keys when complete
- Awaitility.await().atMost(5, TimeUnit.SECONDS)
- .untilAsserted(() -> {
- Assertions.assertEquals(repo.getCacheSize(), 0);
- });
}
@Override
@@ -78,16 +62,7 @@ public class SqsConsumerMessageLocalstackIT extends
Aws2SQSBaseTest {
fromF("aws2-sqs://%s?deleteAfterRead=false&deleteIfFiltered=true&autoCreateQueue=true",
sharedNameGenerator.getName())
- .routeId("sqsConsumer")
.startupOrder(1)
- .process(e -> {
- String key =
e.getMessage().getHeader(Sqs2Constants.MESSAGE_ID, String.class);
- log.info("Processing SQS: {}", key);
- // should be in-progress
- Sqs2Endpoint sqs = (Sqs2Endpoint)
context.getRoute("sqsConsumer").getEndpoint();
- MemoryIdempotentRepository repo =
(MemoryIdempotentRepository) sqs.getInProgressRepository();
- Assertions.assertTrue(repo.getCacheSize() > 0);
- })
.filter(simple("${body} !=
'ignore'")).log("${body}").log("${header.CamelAwsSqsReceiptHandle}")
.to("mock:result");
}
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 1da94bed5c6..f51b4209333 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
@@ -1609,42 +1609,6 @@ public interface Sqs2EndpointBuilderFactory {
doSetProperty("exchangePattern", exchangePattern);
return this;
}
- /**
- * A pluggable in-progress repository
- * org.apache.camel.spi.IdempotentRepository. The in-progress
repository
- * is used to account the current in progress messages being consumed.
- * By default a memory based repository is used.
- *
- * The option is a:
- * <code>org.apache.camel.spi.IdempotentRepository</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param inProgressRepository the value to set
- * @return the dsl builder
- */
- default AdvancedSqs2EndpointConsumerBuilder
inProgressRepository(org.apache.camel.spi.IdempotentRepository
inProgressRepository) {
- doSetProperty("inProgressRepository", inProgressRepository);
- return this;
- }
- /**
- * A pluggable in-progress repository
- * org.apache.camel.spi.IdempotentRepository. The in-progress
repository
- * is used to account the current in progress messages being consumed.
- * By default a memory based repository is used.
- *
- * The option will be converted to a
- * <code>org.apache.camel.spi.IdempotentRepository</code> type.
- *
- * Group: consumer (advanced)
- *
- * @param inProgressRepository the value to set
- * @return the dsl builder
- */
- default AdvancedSqs2EndpointConsumerBuilder
inProgressRepository(String inProgressRepository) {
- doSetProperty("inProgressRepository", inProgressRepository);
- return this;
- }
/**
* A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing
* you to provide your custom implementation to control error handling
diff --git
a/dsl/camel-kotlin-api/src/generated/kotlin/org/apache/camel/kotlin/components/Aws2SqsUriDsl.kt
b/dsl/camel-kotlin-api/src/generated/kotlin/org/apache/camel/kotlin/components/Aws2SqsUriDsl.kt
index 2bd30132a12..fa2caa5ac41 100644
---
a/dsl/camel-kotlin-api/src/generated/kotlin/org/apache/camel/kotlin/components/Aws2SqsUriDsl.kt
+++
b/dsl/camel-kotlin-api/src/generated/kotlin/org/apache/camel/kotlin/components/Aws2SqsUriDsl.kt
@@ -373,15 +373,6 @@ public class Aws2SqsUriDsl(
it.property("exchangePattern", exchangePattern)
}
- /**
- * A pluggable in-progress repository
org.apache.camel.spi.IdempotentRepository. The in-progress
- * repository is used to account the current in progress messages being
consumed. By default a memory
- * based repository is used.
- */
- public fun inProgressRepository(inProgressRepository: String) {
- it.property("inProgressRepository", inProgressRepository)
- }
-
/**
* A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing you
to provide your custom
* implementation to control error handling usually occurred during the poll
operation before an
