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 07:00:13 UTC
[camel] 02/05: CAMEL-16293 - Camel-AWS2-Components: Autocreation of
entities should be false by default - camel-aws2-sns
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 <an...@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());
}
};
}