You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/03/08 06:29:20 UTC
[camel] 02/05: CAMEL-16293 - Camel-AWS2-Components: Autocreation of
entities should be false by default - camel-aws2-sqs
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6084e85f28f18eaefd45ca9229b93ffdf943b79c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Mar 8 06:59:39 2021 +0100
CAMEL-16293 - Camel-AWS2-Components: Autocreation of entities should be false by default - camel-aws2-sqs
---
.../org/apache/camel/catalog/docs/aws2-sqs-component.adoc | 4 ++--
.../org/apache/camel/component/aws2/sqs/aws2-sqs.json | 4 ++--
.../camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc | 4 ++--
.../aws2/sqs/integration/SqsComponentIntegrationTest.java | 2 +-
.../sqs/integration/SqsConsumerMessageIntegrationTest.java | 5 +++--
.../aws2/sqs/localstack/SqsComponentLocalstackTest.java | 2 +-
.../sqs/localstack/SqsConsumerMessageLocalstackTest.java | 4 ++--
.../localstack/SqsProducerBatchSendFifoLocalstackTest.java | 4 ++--
.../sqs/localstack/SqsProducerBatchSendLocalstackTest.java | 4 ++--
.../SqsProducerBatchSendWithSeparatorLocalstackTest.java | 4 ++--
.../localstack/SqsProducerDeleteMessageLocalstackTest.java | 4 ++--
.../component/dsl/Aws2SqsComponentBuilderFactory.java | 2 +-
.../builder/endpoint/dsl/Sqs2EndpointBuilderFactory.java | 12 ++++++------
docs/components/modules/ROOT/pages/aws2-sqs-component.adoc | 4 ++--
14 files changed, 30 insertions(+), 29 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc
index 04a80cd..6955a7d 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/docs/aws2-sqs-component.adoc
@@ -52,7 +52,7 @@ The AWS 2 Simple Queue Service (SQS) component supports 43 options, which are li
| Name | Description | Default | Type
| *amazonAWSHost* (common) | The hostname of the Amazon AWS cloud. | amazonaws.com | String
| *amazonSQSClient* (common) | *Autowired* To use the AmazonSQS as client | | SqsClient
-| *autoCreateQueue* (common) | Setting the autocreation of the queue | true | boolean
+| *autoCreateQueue* (common) | Setting the autocreation of the queue | false | boolean
| *configuration* (common) | The AWS SQS default configuration | | Sqs2Configuration
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | boolean
| *protocol* (common) | The underlying protocol used to communicate with SQS | https | String
@@ -130,7 +130,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amazonAWSHost* (common) | The hostname of the Amazon AWS cloud. | amazonaws.com | String
| *amazonSQSClient* (common) | *Autowired* To use the AmazonSQS as client | | SqsClient
-| *autoCreateQueue* (common) | Setting the autocreation of the queue | true | boolean
+| *autoCreateQueue* (common) | Setting the autocreation of the queue | false | boolean
| *headerFilterStrategy* (common) | To use a custom HeaderFilterStrategy to map headers to/from Camel. | | HeaderFilterStrategy
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | boolean
| *protocol* (common) | The underlying protocol used to communicate with SQS | https | String
diff --git a/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json b/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
index 9886d5e..426106a 100644
--- a/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
+++ b/components/camel-aws2-sqs/src/generated/resources/org/apache/camel/component/aws2/sqs/aws2-sqs.json
@@ -24,7 +24,7 @@
"componentProperties": {
"amazonAWSHost": { "kind": "property", "displayName": "Amazon AWSHost", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "amazonaws.com", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The hostname of the Amazon AWS cloud." },
"amazonSQSClient": { "kind": "property", "displayName": "Amazon SQSClient", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.sqs.SqsClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To use the AmazonSQS as client" },
- "autoCreateQueue": { "kind": "property", "displayName": "Auto Create Queue", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Setting the autocreation of the queue" },
+ "autoCreateQueue": { "kind": "property", "displayName": "Auto Create Queue", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Setting the autocreation of the queue" },
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "deprecated": false, "autowired": false, "secret": false, "description": "The AWS SQS default configuration" },
"overrideEndpoint": { "kind": "property", "displayName": "Override Endpoint", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpoint [...]
"protocol": { "kind": "property", "displayName": "Protocol", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "https", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The underlying protocol used to communicate with SQS" },
@@ -70,7 +70,7 @@
"queueNameOrArn": { "kind": "path", "displayName": "Queue Name Or Arn", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Queue name or ARN" },
"amazonAWSHost": { "kind": "parameter", "displayName": "Amazon AWSHost", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "amazonaws.com", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The hostname of the Amazon AWS cloud." },
"amazonSQSClient": { "kind": "parameter", "displayName": "Amazon SQSClient", "group": "common", "label": "", "required": false, "type": "object", "javaType": "software.amazon.awssdk.services.sqs.SqsClient", "deprecated": false, "deprecationNote": "", "autowired": true, "secret": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "To use the AmazonSQS as client" },
- "autoCreateQueue": { "kind": "parameter", "displayName": "Auto Create Queue", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Setting the autocreation of the queue" },
+ "autoCreateQueue": { "kind": "parameter", "displayName": "Auto Create Queue", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Setting the autocreation of the queue" },
"headerFilterStrategy": { "kind": "parameter", "displayName": "Header Filter Strategy", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.spi.HeaderFilterStrategy", "deprecated": false, "autowired": false, "secret": false, "description": "To use a custom HeaderFilterStrategy to map headers to\/from Camel." },
"overrideEndpoint": { "kind": "parameter", "displayName": "Override Endpoint", "group": "common", "label": "", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpoin [...]
"protocol": { "kind": "parameter", "displayName": "Protocol", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "https", "configurationClass": "org.apache.camel.component.aws2.sqs.Sqs2Configuration", "configurationField": "configuration", "description": "The underlying protocol used to communicate with SQS" },
diff --git a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
index 04a80cd..6955a7d 100644
--- a/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
+++ b/components/camel-aws2-sqs/src/main/docs/aws2-sqs-component.adoc
@@ -52,7 +52,7 @@ The AWS 2 Simple Queue Service (SQS) component supports 43 options, which are li
| Name | Description | Default | Type
| *amazonAWSHost* (common) | The hostname of the Amazon AWS cloud. | amazonaws.com | String
| *amazonSQSClient* (common) | *Autowired* To use the AmazonSQS as client | | SqsClient
-| *autoCreateQueue* (common) | Setting the autocreation of the queue | true | boolean
+| *autoCreateQueue* (common) | Setting the autocreation of the queue | false | boolean
| *configuration* (common) | The AWS SQS default configuration | | Sqs2Configuration
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | boolean
| *protocol* (common) | The underlying protocol used to communicate with SQS | https | String
@@ -130,7 +130,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amazonAWSHost* (common) | The hostname of the Amazon AWS cloud. | amazonaws.com | String
| *amazonSQSClient* (common) | *Autowired* To use the AmazonSQS as client | | SqsClient
-| *autoCreateQueue* (common) | Setting the autocreation of the queue | true | boolean
+| *autoCreateQueue* (common) | Setting the autocreation of the queue | false | boolean
| *headerFilterStrategy* (common) | To use a custom HeaderFilterStrategy to map headers to/from Camel. | | HeaderFilterStrategy
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | boolean
| *protocol* (common) | The underlying protocol used to communicate with SQS | https | String
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsComponentIntegrationTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsComponentIntegrationTest.java
index d38d2ab..6465550 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsComponentIntegrationTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsComponentIntegrationTest.java
@@ -106,7 +106,7 @@ public class SqsComponentIntegrationTest extends CamelTestSupport {
AwsCredentials credentials = credentialsProvider.resolveCredentials();
final String sqsEndpointUri = String
- .format("aws2-sqs://%s?accessKey=%s&secretKey=%s&messageRetentionPeriod=%s&maximumMessageSize=%s&visibilityTimeout=%s&policy=%s&configuration=%s",
+ .format("aws2-sqs://%s?accessKey=%s&secretKey=%s&messageRetentionPeriod=%s&maximumMessageSize=%s&visibilityTimeout=%s&policy=%s&configuration=%s&autoCreateQueue=true",
sharedNameGenerator.getName(),
credentials.accessKeyId(),
credentials.secretAccessKey(),
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageIntegrationTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageIntegrationTest.java
index 6bd8cce..856e76c 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageIntegrationTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/integration/SqsConsumerMessageIntegrationTest.java
@@ -73,7 +73,8 @@ public class SqsConsumerMessageIntegrationTest extends CamelTestSupport {
AwsCredentials credentials = credentialsProvider.resolveCredentials();
final String sqsEndpointUri
- = String.format("aws2-sqs://%s?accessKey=RAW(%s)&secretKey=RAW(%s)®ion=eu-west-1&configuration=%s",
+ = String.format(
+ "aws2-sqs://%s?accessKey=RAW(%s)&secretKey=RAW(%s)®ion=eu-west-1&configuration=%s&autoCreateQueue=true",
sharedNameGenerator.getName(),
credentials.accessKeyId(),
credentials.secretAccessKey(),
@@ -84,7 +85,7 @@ public class SqsConsumerMessageIntegrationTest extends CamelTestSupport {
public void configure() throws Exception {
from("direct:start").startupOrder(2).to(sqsEndpointUri);
- fromF("aws2-sqs://%s?accessKey=RAW(%s)&secretKey=RAW(%s)®ion=eu-west-1&deleteAfterRead=false&deleteIfFiltered=true&configuration=%s",
+ fromF("aws2-sqs://%s?accessKey=RAW(%s)&secretKey=RAW(%s)®ion=eu-west-1&deleteAfterRead=false&deleteIfFiltered=true&configuration=%s&autoCreateQueue=true",
sharedNameGenerator.getName(),
credentials.accessKeyId(),
credentials.secretAccessKey(),
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsComponentLocalstackTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsComponentLocalstackTest.java
index d6ed735..04a12ad 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsComponentLocalstackTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsComponentLocalstackTest.java
@@ -88,7 +88,7 @@ public class SqsComponentLocalstackTest extends Aws2SQSBaseTest {
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
final String sqsEndpointUri = String
- .format("aws2-sqs://%s?messageRetentionPeriod=%s&maximumMessageSize=%s&visibilityTimeout=%s&policy=%s",
+ .format("aws2-sqs://%s?messageRetentionPeriod=%s&maximumMessageSize=%s&visibilityTimeout=%s&policy=%s&autoCreateQueue=true",
sharedNameGenerator.getName(),
"1209600", "65536", "60",
"file:src/test/resources/org/apache/camel/component/aws2/sqs/policy.txt");
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsConsumerMessageLocalstackTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsConsumerMessageLocalstackTest.java
index e761ca1..7fd843d 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsConsumerMessageLocalstackTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsConsumerMessageLocalstackTest.java
@@ -58,9 +58,9 @@ public class SqsConsumerMessageLocalstackTest extends Aws2SQSBaseTest {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:start").startupOrder(2).toF("aws2-sqs://%s", sharedNameGenerator.getName());
+ from("direct:start").startupOrder(2).toF("aws2-sqs://%s?autoCreateQueue=true", sharedNameGenerator.getName());
- fromF("aws2-sqs://%s?deleteAfterRead=false&deleteIfFiltered=true", sharedNameGenerator.getName())
+ fromF("aws2-sqs://%s?deleteAfterRead=false&deleteIfFiltered=true&autoCreateQueue=true", sharedNameGenerator.getName())
.startupOrder(1)
.filter(simple("${body} != 'ignore'")).log("${body}").log("${header.CamelAwsSqsReceiptHandle}")
.to("mock:result");
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendFifoLocalstackTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendFifoLocalstackTest.java
index 767af64..850afb3 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendFifoLocalstackTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendFifoLocalstackTest.java
@@ -56,7 +56,7 @@ public class SqsProducerBatchSendFifoLocalstackTest extends Aws2SQSBaseTest {
protected RouteBuilder createRouteBuilder() throws Exception {
final String sqsEndpointUri = String.format(
"aws2-sqs://%s.fifo?messageGroupIdStrategy=useExchangeId"
- + "&messageDeduplicationIdStrategy=useContentBasedDeduplication",
+ + "&messageDeduplicationIdStrategy=useContentBasedDeduplication&autoCreateQueue=true",
sharedNameGenerator.getName());
return new RouteBuilder() {
@@ -65,7 +65,7 @@ public class SqsProducerBatchSendFifoLocalstackTest extends Aws2SQSBaseTest {
from("direct:start").startupOrder(2).setHeader(Sqs2Constants.SQS_OPERATION, constant("sendBatchMessage"))
.to(sqsEndpointUri);
- fromF("aws2-sqs://%s.fifo?deleteAfterRead=false", sharedNameGenerator.getName())
+ fromF("aws2-sqs://%s.fifo?deleteAfterRead=false&autoCreateQueue=true", sharedNameGenerator.getName())
.startupOrder(1).log("${body}").to("mock:result");
}
};
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendLocalstackTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendLocalstackTest.java
index 9aab850..aac63f4 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendLocalstackTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendLocalstackTest.java
@@ -63,9 +63,9 @@ public class SqsProducerBatchSendLocalstackTest extends Aws2SQSBaseTest {
@Override
public void configure() throws Exception {
from("direct:start").startupOrder(2).setHeader(Sqs2Constants.SQS_OPERATION, constant("sendBatchMessage"))
- .toF("aws2-sqs://%s", sharedNameGenerator.getName());
+ .toF("aws2-sqs://%s?autoCreateQueue=true", sharedNameGenerator.getName());
- fromF("aws2-sqs://%s?deleteAfterRead=true", sharedNameGenerator.getName())
+ fromF("aws2-sqs://%s?deleteAfterRead=true&autoCreateQueue=true", sharedNameGenerator.getName())
.startupOrder(1).log("${body}").to("mock:result");
}
};
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendWithSeparatorLocalstackTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendWithSeparatorLocalstackTest.java
index 9c9149b..e287e18 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendWithSeparatorLocalstackTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerBatchSendWithSeparatorLocalstackTest.java
@@ -54,9 +54,9 @@ public class SqsProducerBatchSendWithSeparatorLocalstackTest extends Aws2SQSBase
@Override
public void configure() throws Exception {
from("direct:start").startupOrder(2).setHeader(Sqs2Constants.SQS_OPERATION, constant("sendBatchMessage"))
- .toF("aws2-sqs://%s", sharedNameGenerator.getName());
+ .toF("aws2-sqs://%s?autoCreateQueue=true", sharedNameGenerator.getName());
- fromF("aws2-sqs://%s?deleteAfterRead=true", sharedNameGenerator.getName())
+ fromF("aws2-sqs://%s?deleteAfterRead=true&autoCreateQueue=true", sharedNameGenerator.getName())
.startupOrder(1).log("${body}").to("mock:result");
}
};
diff --git a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerDeleteMessageLocalstackTest.java b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerDeleteMessageLocalstackTest.java
index 31602a3..98d3870 100644
--- a/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerDeleteMessageLocalstackTest.java
+++ b/components/camel-aws2-sqs/src/test/java/org/apache/camel/component/aws2/sqs/localstack/SqsProducerDeleteMessageLocalstackTest.java
@@ -52,9 +52,9 @@ public class SqsProducerDeleteMessageLocalstackTest extends Aws2SQSBaseTest {
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:start").startupOrder(2).toF("aws2-sqs://%s", sharedNameGenerator.getName());
+ from("direct:start").startupOrder(2).toF("aws2-sqs://%s?autoCreateQueue=true", sharedNameGenerator.getName());
- fromF("aws2-sqs://%s?deleteAfterRead=false", sharedNameGenerator.getName())
+ fromF("aws2-sqs://%s?deleteAfterRead=false&autoCreateQueue=true", sharedNameGenerator.getName())
.startupOrder(1).log("${body}")
.toF("aws2-sqs://%s?operation=deleteMessage", sharedNameGenerator.getName())
.log("${body}")
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java
index ba5a3c3..ea05f87 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2SqsComponentBuilderFactory.java
@@ -87,7 +87,7 @@ public interface Aws2SqsComponentBuilderFactory {
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: common
*
* @param autoCreateQueue the value to set
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 fe96b49..1f200ad 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
@@ -101,7 +101,7 @@ public interface Sqs2EndpointBuilderFactory {
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: common
*
* @param autoCreateQueue the value to set
@@ -118,7 +118,7 @@ public interface Sqs2EndpointBuilderFactory {
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: true
+ * Default: false
* Group: common
*
* @param autoCreateQueue the value to set
@@ -1756,7 +1756,7 @@ public interface Sqs2EndpointBuilderFactory {
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: common
*
* @param autoCreateQueue the value to set
@@ -1773,7 +1773,7 @@ public interface Sqs2EndpointBuilderFactory {
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: true
+ * Default: false
* Group: common
*
* @param autoCreateQueue the value to set
@@ -2551,7 +2551,7 @@ public interface Sqs2EndpointBuilderFactory {
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
+ * Default: false
* Group: common
*
* @param autoCreateQueue the value to set
@@ -2567,7 +2567,7 @@ public interface Sqs2EndpointBuilderFactory {
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: true
+ * Default: false
* Group: common
*
* @param autoCreateQueue the value to set
diff --git a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
index e3c35b1..f52973b 100644
--- a/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
+++ b/docs/components/modules/ROOT/pages/aws2-sqs-component.adoc
@@ -54,7 +54,7 @@ The AWS 2 Simple Queue Service (SQS) component supports 43 options, which are li
| Name | Description | Default | Type
| *amazonAWSHost* (common) | The hostname of the Amazon AWS cloud. | amazonaws.com | String
| *amazonSQSClient* (common) | *Autowired* To use the AmazonSQS as client | | SqsClient
-| *autoCreateQueue* (common) | Setting the autocreation of the queue | true | boolean
+| *autoCreateQueue* (common) | Setting the autocreation of the queue | false | boolean
| *configuration* (common) | The AWS SQS default configuration | | Sqs2Configuration
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | boolean
| *protocol* (common) | The underlying protocol used to communicate with SQS | https | String
@@ -132,7 +132,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amazonAWSHost* (common) | The hostname of the Amazon AWS cloud. | amazonaws.com | String
| *amazonSQSClient* (common) | *Autowired* To use the AmazonSQS as client | | SqsClient
-| *autoCreateQueue* (common) | Setting the autocreation of the queue | true | boolean
+| *autoCreateQueue* (common) | Setting the autocreation of the queue | false | boolean
| *headerFilterStrategy* (common) | To use a custom HeaderFilterStrategy to map headers to/from Camel. | | HeaderFilterStrategy
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride option | false | boolean
| *protocol* (common) | The underlying protocol used to communicate with SQS | https | String