This is an automated email from the ASF dual-hosted git repository. orpiske pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 860157b69d0c1c4797e80db3d2222b07bb754a96 Author: Otavio Rodolfo Piske <[email protected]> AuthorDate: Wed Apr 28 11:08:34 2021 +0200 Added a configuration for controlling queue auto-creation --- .../kafkaconnector/aws/v2/sqs/sink/CamelAWSSQSPropertyFactory.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelAWSSQSPropertyFactory.java b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelAWSSQSPropertyFactory.java index 91ed4bf..60b5803 100644 --- a/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelAWSSQSPropertyFactory.java +++ b/tests/itests-aws-v2/src/test/java/org/apache/camel/kafkaconnector/aws/v2/sqs/sink/CamelAWSSQSPropertyFactory.java @@ -72,6 +72,10 @@ final class CamelAWSSQSPropertyFactory extends SinkConnectorPropertyFactory<Came return setProperty("camel.sink.path.queueNameOrArn", queueNameOrArn); } + public CamelAWSSQSPropertyFactory withAutoCreateQueue(boolean value) { + return setProperty("camel.sink.endpoint.autoCreateQueue", value); + } + public static CamelAWSSQSPropertyFactory basic() { return new CamelAWSSQSPropertyFactory() .withName("CamelAws2sqsSinkConnector")
