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 4ae817ec6118c7cc6b5d881aad4b462a34fabc63 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Mon Mar 8 07:47:58 2021 +0100 CAMEL-16293 - Camel-AWS2-Components: Autocreation of entities should be false by default - camel-aws2-sns --- .../component/aws2/sns/integration/SnsComponentFifoIntegrationTest.java | 2 +- .../component/aws2/sns/integration/SnsComponentIntegrationTest.java | 2 +- .../aws2/sns/integration/SnsTopicWithKmsEncryptionIntegrationTest.java | 2 +- .../aws2/sns/localstack/SnsTopicProducerCustomConfigLocalstackTest.java | 2 +- .../component/aws2/sns/localstack/SnsTopicProducerLocalstackTest.java | 2 +- 5 files changed, 5 insertions(+), 5 deletions(-) diff --git a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoIntegrationTest.java b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoIntegrationTest.java index 0662a46..9345be1 100644 --- a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoIntegrationTest.java +++ b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentFifoIntegrationTest.java @@ -60,7 +60,7 @@ public class SnsComponentFifoIntegrationTest extends CamelTestSupport { @Override public void configure() throws Exception { from("direct:start") - .to("aws2-sns://Order.fifo?accessKey=RAW(xxxx)&secretKey=RAW(yyyy)®ion=eu-west-1&subject=The+subject+message&messageGroupIdStrategy=useExchangeId"); + .to("aws2-sns://Order.fifo?accessKey=RAW(xxxx)&secretKey=RAW(yyyy)®ion=eu-west-1&subject=The+subject+message&messageGroupIdStrategy=useExchangeId&autoCreateTopic=true"); } }; } diff --git a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentIntegrationTest.java b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentIntegrationTest.java index 01fd6ec..c793dff 100644 --- a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentIntegrationTest.java +++ b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsComponentIntegrationTest.java @@ -61,7 +61,7 @@ public class SnsComponentIntegrationTest extends CamelTestSupport { public void configure() throws Exception { from("direct:start") .to("aws2-sns://MyNewTopic?accessKey=xxx&secretKey=yyy&policy=%7B%22Version%22%3A%222008-10-17%22,%22Statement%22%3A%5B%7B%22Sid%22%3A%221%22,%22Effect%22%3A%22Allow%22," - + "%22Principal%22%3A%7B%22AWS%22%3A%5B%22*%22%5D%7D,%22Action%22%3A%5B%22sns%3ASubscribe%22%5D%7D%5D%7D&subject=The+subject+message"); + + "%22Principal%22%3A%7B%22AWS%22%3A%5B%22*%22%5D%7D,%22Action%22%3A%5B%22sns%3ASubscribe%22%5D%7D%5D%7D&subject=The+subject+message&autoCreateTopic=true"); } }; } diff --git a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionIntegrationTest.java b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionIntegrationTest.java index 0ece366..425267a 100644 --- a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionIntegrationTest.java +++ b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/integration/SnsTopicWithKmsEncryptionIntegrationTest.java @@ -60,7 +60,7 @@ public class SnsTopicWithKmsEncryptionIntegrationTest extends CamelTestSupport { @Override public void configure() throws Exception { from("direct:start") - .to("aws2-sns://MyNewTopic1?accessKey=RAW(xxxx)&secretKey=RAW(xxxx)®ion=EU_WEST_1&subject=The+subject+message&serverSideEncryptionEnabled=true&kmsMasterKeyId=RAW(xxx)"); + .to("aws2-sns://MyNewTopic1?accessKey=RAW(xxxx)&secretKey=RAW(xxxx)®ion=EU_WEST_1&subject=The+subject+message&serverSideEncryptionEnabled=true&kmsMasterKeyId=RAW(xxx)&autoCreateTopic=true"); } }; } diff --git a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerCustomConfigLocalstackTest.java b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerCustomConfigLocalstackTest.java index d096e22..aa3a4c8 100644 --- a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerCustomConfigLocalstackTest.java +++ b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerCustomConfigLocalstackTest.java @@ -63,7 +63,7 @@ public class SnsTopicProducerCustomConfigLocalstackTest extends Aws2SNSBaseTest @Override public void configure() throws Exception { from("direct:start") - .toF("aws2-sns://%s?subject=The+subject+message&configuration=#class:%s", + .toF("aws2-sns://%s?subject=The+subject+message&configuration=#class:%s&autoCreateTopic=true", sharedNameGenerator.getName(), TestSnsConfiguration.class.getName()); } }; diff --git a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerLocalstackTest.java b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerLocalstackTest.java index d190aec..d25034f 100644 --- a/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerLocalstackTest.java +++ b/components/camel-aws2-sns/src/test/java/org/apache/camel/component/aws2/sns/localstack/SnsTopicProducerLocalstackTest.java @@ -63,7 +63,7 @@ public class SnsTopicProducerLocalstackTest extends Aws2SNSBaseTest { @Override public void configure() throws Exception { from("direct:start") - .toF("aws2-sns://%s?subject=The+subject+message", sharedNameGenerator.getName()); + .toF("aws2-sns://%s?subject=The+subject+message&autoCreateTopic=true", sharedNameGenerator.getName()); } }; }