This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new bfdc948 [aws2sqs] Add deleteQueue operation to aws2sqs component
bfdc948 is described below
commit bfdc948a9a292bc0a579ad055f52ee1d88d38226
Author: Vratislav Hais <vh...@redhat.com>
AuthorDate: Tue Sep 7 07:30:37 2021 +0200
[aws2sqs] Add deleteQueue operation to aws2sqs component
---
.../apache/camel/component/aws2/sqs/aws2-sqs.json | 4 +-
.../src/main/docs/aws2-sqs-component.adoc | 4 +-
.../camel/component/aws2/sqs/Sqs2Operations.java | 3 +-
.../camel/component/aws2/sqs/Sqs2Producer.java | 15 +++++
.../component/aws2/sqs/AmazonSQSClientMock.java | 8 +++
.../aws2/sqs/SqsProducerDeleteQueueTest.java | 67 ++++++++++++++++++++++
.../endpoint/dsl/Sqs2EndpointBuilderFactory.java | 3 +-
.../modules/ROOT/pages/aws2-sqs-component.adoc | 4 +-
8 files changed, 100 insertions(+), 8 deletions(-)
diff --git
a/components/camel-aws/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
b/components/camel-aws/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
index 9e58675..1d2fd3d 100644
---
a/components/camel-aws/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
+++
b/components/camel-aws/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
@@ -52,7 +52,7 @@
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during star [...]
"messageDeduplicationIdStrategy": { "kind": "property", "displayName":
"Message Deduplication Id Strategy", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"useExchangeId", "useContentBasedDeduplication" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "useExchangeId",
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", [...]
"messageGroupIdStrategy": { "kind": "property", "displayName": "Message
Group Id Strategy", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [
"useConstant", "useExchangeId", "usePropertyValue" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Only for FIFO queues. Strateg [...]
- "operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.sqs.Sqs2Operations", "enum": [
"sendBatchMessage", "deleteMessage", "listQueues", "purgeQueue" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "The operati [...]
+ "operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.sqs.Sqs2Operations", "enum": [
"sendBatchMessage", "deleteMessage", "listQueues", "purgeQueue", "deleteQueue"
], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "description [...]
"autowiredEnabled": { "kind": "property", "displayName": "Autowired
Enabled", "group": "advanced", "label": "advanced", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "description": "Whether autowiring is
enabled. This is used for automatic autowiring options (the option must be
marked as autowired) by looking up in the registry to find if there is a single
instance of matching type, which t [...]
"delayQueue": { "kind": "property", "displayName": "Delay Queue", "group":
"advanced", "label": "advanced", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Define if you want to apply delaySeconds
option to the queue or on single messages" },
"queueUrl": { "kind": "property", "displayName": "Queue Url", "group":
"advanced", "label": "advanced", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "To define the queueUrl explicitly. All other
parameters, which would influence the queueUrl, are ignored. This parameter is
[...]
@@ -103,7 +103,7 @@
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during sta [...]
"messageDeduplicationIdStrategy": { "kind": "parameter", "displayName":
"Message Deduplication Id Strategy", "group": "producer", "label": "producer",
"required": false, "type": "string", "javaType": "java.lang.String", "enum": [
"useExchangeId", "useContentBasedDeduplication" ], "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "useExchangeId",
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration" [...]
"messageGroupIdStrategy": { "kind": "parameter", "displayName": "Message
Group Id Strategy", "group": "producer", "label": "producer", "required":
false, "type": "string", "javaType": "java.lang.String", "enum": [
"useConstant", "useExchangeId", "usePropertyValue" ], "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Only for FIFO queues. Strate [...]
- "operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.sqs.Sqs2Operations", "enum": [
"sendBatchMessage", "deleteMessage", "listQueues", "purgeQueue" ],
"deprecated": false, "autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "The operat [...]
+ "operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "producer", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.sqs.Sqs2Operations", "enum": [
"sendBatchMessage", "deleteMessage", "listQueues", "purgeQueue", "deleteQueue"
], "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "descriptio [...]
"delayQueue": { "kind": "parameter", "displayName": "Delay Queue",
"group": "advanced", "label": "advanced", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "Define if you want to apply delaySeconds
option to the queue or on single messages" },
"queueUrl": { "kind": "parameter", "displayName": "Queue Url", "group":
"advanced", "label": "advanced", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField":
"configuration", "description": "To define the queueUrl explicitly. All other
parameters, which would influence the queueUrl, are ignored. This parameter i
[...]
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group":
"proxy", "label": "proxy", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the SQS client" },
diff --git
a/components/camel-aws/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
b/components/camel-aws/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
index 2fb7586..e20a587 100644
--- a/components/camel-aws/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
+++ b/components/camel-aws/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
@@ -110,7 +110,7 @@ The AWS Simple Queue Service (SQS) component supports 43
options, which are list
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
| *messageGroupIdStrategy* (producer) | Only for FIFO queues. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. There are 3 enums
and the value can be one of: useConstant, useExchangeId, usePropertyValue | |
String
-| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 4 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue | | Sqs2Operations
+| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 5 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue, deleteQueue | |
Sqs2Operations
| *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used
for automatic autowiring options (the option must be marked as autowired) by
looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
| *delayQueue* (advanced) | Define if you want to apply delaySeconds option to
the queue or on single messages | false | boolean
| *queueUrl* (advanced) | To define the queueUrl explicitly. All other
parameters, which would influence the queueUrl, are ignored. This parameter is
intended to be used, to connect to a mock implementation of SQS, for testing
purposes. | | String
@@ -188,7 +188,7 @@ with the following path and query parameters:
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
| *messageGroupIdStrategy* (producer) | Only for FIFO queues. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. There are 3 enums
and the value can be one of: useConstant, useExchangeId, usePropertyValue | |
String
-| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 4 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue | | Sqs2Operations
+| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 5 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue, deleteQueue | |
Sqs2Operations
| *delayQueue* (advanced) | Define if you want to apply delaySeconds option to
the queue or on single messages | false | boolean
| *queueUrl* (advanced) | To define the queueUrl explicitly. All other
parameters, which would influence the queueUrl, are ignored. This parameter is
intended to be used, to connect to a mock implementation of SQS, for testing
purposes. | | String
| *proxyHost* (proxy) | To define a proxy host when instantiating the SQS
client | | String
diff --git
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Operations.java
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Operations.java
index 3bd427e..0c7fb86 100644
---
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Operations.java
+++
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Operations.java
@@ -21,5 +21,6 @@ public enum Sqs2Operations {
sendBatchMessage,
deleteMessage,
listQueues,
- purgeQueue
+ purgeQueue,
+ deleteQueue
}
diff --git
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
index e168517..aeab1bc 100644
---
a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
+++
b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Producer.java
@@ -37,6 +37,8 @@ import software.amazon.awssdk.core.SdkBytes;
import software.amazon.awssdk.services.sqs.SqsClient;
import software.amazon.awssdk.services.sqs.model.DeleteMessageRequest;
import software.amazon.awssdk.services.sqs.model.DeleteMessageResponse;
+import software.amazon.awssdk.services.sqs.model.DeleteQueueRequest;
+import software.amazon.awssdk.services.sqs.model.DeleteQueueResponse;
import software.amazon.awssdk.services.sqs.model.ListQueuesRequest;
import software.amazon.awssdk.services.sqs.model.ListQueuesResponse;
import software.amazon.awssdk.services.sqs.model.MessageAttributeValue;
@@ -85,6 +87,9 @@ public class Sqs2Producer extends DefaultProducer {
case purgeQueue:
purgeQueue(getClient(), exchange);
break;
+ case deleteQueue:
+ deleteQueue(getClient(), exchange);
+ break;
default:
throw new IllegalArgumentException("Unsupported
operation");
}
@@ -185,6 +190,16 @@ public class Sqs2Producer extends DefaultProducer {
message.setBody(result);
}
+ private void deleteQueue(SqsClient amazonSQS, Exchange exchange) {
+ DeleteQueueRequest.Builder request = DeleteQueueRequest.builder();
+ if
(ObjectHelper.isNotEmpty(exchange.getIn().getHeader(Sqs2Constants.SQS_QUEUE_PREFIX)))
{
+ request.queueUrl(getQueueUrl());
+ }
+ DeleteQueueResponse result = amazonSQS.deleteQueue(request.build());
+ Message message = getMessageForResponse(exchange);
+ message.setBody(result);
+ }
+
private void configureFifoAttributes(SendMessageRequest.Builder request,
Exchange exchange) {
if (getEndpoint().getConfiguration().isFifoQueue()) {
// use strategies
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
index 2be4289..ec48869 100644
---
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/AmazonSQSClientMock.java
@@ -38,6 +38,8 @@ import
software.amazon.awssdk.services.sqs.model.CreateQueueRequest;
import software.amazon.awssdk.services.sqs.model.CreateQueueResponse;
import software.amazon.awssdk.services.sqs.model.DeleteMessageRequest;
import software.amazon.awssdk.services.sqs.model.DeleteMessageResponse;
+import software.amazon.awssdk.services.sqs.model.DeleteQueueRequest;
+import software.amazon.awssdk.services.sqs.model.DeleteQueueResponse;
import software.amazon.awssdk.services.sqs.model.GetQueueUrlRequest;
import software.amazon.awssdk.services.sqs.model.GetQueueUrlResponse;
import software.amazon.awssdk.services.sqs.model.ListQueuesRequest;
@@ -189,6 +191,12 @@ public class AmazonSQSClientMock implements SqsClient {
}
@Override
+ public DeleteQueueResponse deleteQueue(DeleteQueueRequest
deleteQueueRequest)
+ throws AwsServiceException, SdkClientException, SqsException {
+ return DeleteQueueResponse.builder().build();
+ }
+
+ @Override
public SetQueueAttributesResponse
setQueueAttributes(SetQueueAttributesRequest setQueueAttributesRequest) {
synchronized (queueAttributes) {
if
(!queueAttributes.containsKey(setQueueAttributesRequest.queueUrl())) {
diff --git
a/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerDeleteQueueTest.java
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerDeleteQueueTest.java
new file mode 100644
index 0000000..b962091
--- /dev/null
+++
b/components/camel-aws/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/SqsProducerDeleteQueueTest.java
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.aws2.sqs;
+
+import org.apache.camel.BindToRegistry;
+import org.apache.camel.EndpointInject;
+import org.apache.camel.Exchange;
+import org.apache.camel.Processor;
+import org.apache.camel.ProducerTemplate;
+import org.apache.camel.builder.RouteBuilder;
+import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.camel.test.junit5.CamelTestSupport;
+import org.junit.jupiter.api.Test;
+import software.amazon.awssdk.services.sqs.model.DeleteQueueResponse;
+
+import static org.junit.jupiter.api.Assertions.assertNotNull;
+
+public class SqsProducerDeleteQueueTest extends CamelTestSupport {
+ @BindToRegistry("client")
+ AmazonSQSClientMock mock = new AmazonSQSClientMock();
+
+ @EndpointInject("direct:start")
+ private ProducerTemplate template;
+
+ @EndpointInject("mock:result")
+ private MockEndpoint result;
+
+ @Test
+ public void deleteMessage() throws Exception {
+ result.expectedMessageCount(1);
+
+ template.send("direct:start", new Processor() {
+
+ @Override
+ public void process(Exchange exchange) throws Exception {
+ exchange.getIn().setHeader(Sqs2Constants.SQS_QUEUE_PREFIX,
"camel-1");
+ }
+ });
+ assertMockEndpointsSatisfied();
+ DeleteQueueResponse res =
result.getExchanges().get(0).getIn().getBody(DeleteQueueResponse.class);
+ assertNotNull(res);
+ }
+
+ @Override
+ protected RouteBuilder createRouteBuilder() throws Exception {
+ return new RouteBuilder() {
+ @Override
+ public void configure() throws Exception {
+
from("direct:start").to("aws2-sqs://camel-1?amazonSQSClient=#client&operation=deleteQueue").to("mock:result");
+ }
+ };
+ }
+}
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
index dfa20167..ea83596 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java
@@ -3090,7 +3090,8 @@ public interface Sqs2EndpointBuilderFactory {
sendBatchMessage,
deleteMessage,
listQueues,
- purgeQueue;
+ purgeQueue,
+ deleteQueue;
}
public interface Sqs2Builders {
diff --git a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
index 70467ed..7a867c2 100644
--- a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
@@ -112,7 +112,7 @@ The AWS Simple Queue Service (SQS) component supports 43
options, which are list
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
| *messageGroupIdStrategy* (producer) | Only for FIFO queues. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. There are 3 enums
and the value can be one of: useConstant, useExchangeId, usePropertyValue | |
String
-| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 4 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue | | Sqs2Operations
+| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 5 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue, deleteQueue | |
Sqs2Operations
| *autowiredEnabled* (advanced) | Whether autowiring is enabled. This is used
for automatic autowiring options (the option must be marked as autowired) by
looking up in the registry to find if there is a single instance of matching
type, which then gets configured on the component. This can be used for
automatic configuring JDBC data sources, JMS connection factories, AWS Clients,
etc. | true | boolean
| *delayQueue* (advanced) | Define if you want to apply delaySeconds option to
the queue or on single messages | false | boolean
| *queueUrl* (advanced) | To define the queueUrl explicitly. All other
parameters, which would influence the queueUrl, are ignored. This parameter is
intended to be used, to connect to a mock implementation of SQS, for testing
purposes. | | String
@@ -190,7 +190,7 @@ with the following path and query parameters:
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *messageDeduplicationIdStrategy* (producer) | Only for FIFO queues. Strategy
for setting the messageDeduplicationId on the message. Can be one of the
following options: useExchangeId, useContentBasedDeduplication. For the
useContentBasedDeduplication option, no messageDeduplicationId will be set on
the message. There are 2 enums and the value can be one of: useExchangeId,
useContentBasedDeduplication | useExchangeId | String
| *messageGroupIdStrategy* (producer) | Only for FIFO queues. Strategy for
setting the messageGroupId on the message. Can be one of the following options:
useConstant, useExchangeId, usePropertyValue. For the usePropertyValue option,
the value of property CamelAwsMessageGroupId will be used. There are 3 enums
and the value can be one of: useConstant, useExchangeId, usePropertyValue | |
String
-| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 4 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue | | Sqs2Operations
+| *operation* (producer) | The operation to do in case the user don't want to
send only a message. There are 5 enums and the value can be one of:
sendBatchMessage, deleteMessage, listQueues, purgeQueue, deleteQueue | |
Sqs2Operations
| *delayQueue* (advanced) | Define if you want to apply delaySeconds option to
the queue or on single messages | false | boolean
| *queueUrl* (advanced) | To define the queueUrl explicitly. All other
parameters, which would influence the queueUrl, are ignored. This parameter is
intended to be used, to connect to a mock implementation of SQS, for testing
purposes. | | String
| *proxyHost* (proxy) | To define a proxy host when instantiating the SQS
client | | String
