This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch feature/CAMEL-23789-wave1-multi-dsl-docs in repository https://gitbox.apache.org/repos/asf/camel.git
commit e405418af5b4d4f615505cc92e87064db51ed861 Author: Claus Ibsen <[email protected]> AuthorDate: Wed Jun 17 19:04:17 2026 +0200 CAMEL-23789: Make AWS SNS component docs multi-DSL friendly (Wave 1) Co-Authored-By: Claude <[email protected]> Signed-off-by: Claus Ibsen <[email protected]> --- .../src/main/docs/aws2-sns-component.adoc | 67 +++++++++++++--------- 1 file changed, 41 insertions(+), 26 deletions(-) diff --git a/components/camel-aws/camel-aws2-sns/src/main/docs/aws2-sns-component.adoc b/components/camel-aws/camel-aws2-sns/src/main/docs/aws2-sns-component.adoc index 50afc122106e..22519f150305 100644 --- a/components/camel-aws/camel-aws2-sns/src/main/docs/aws2-sns-component.adoc +++ b/components/camel-aws/camel-aws2-sns/src/main/docs/aws2-sns-component.adoc @@ -164,11 +164,42 @@ you'll be able to subscribe your SQS Queue to your SNS Topic. At this point, you can consume messages coming from SNS Topic through your SQS Queue +[tabs] +==== +Java:: ++ [source,java] -------------------------------------------------- +---- from("aws2-sqs://test-camel?amazonSQSClient=#amazonSQSClient&delay=50&maxMessagesPerPoll=5") - .to(...); -------------------------------------------------- + .to("..."); +---- + +XML:: ++ +[source,xml] +---- +<route> + <from uri="aws2-sqs://test-camel?amazonSQSClient=#amazonSQSClient&delay=50&maxMessagesPerPoll=5"/> + <to uri="..."/> +</route> +---- + +YAML:: ++ +[source,yaml] +---- +- route: + from: + uri: aws2-sqs://test-camel + parameters: + amazonSQSClient: "#amazonSQSClient" + delay: 50 + maxMessagesPerPoll: 5 + steps: + - to: + uri: "..." +---- +==== === Topic Auto-creation @@ -275,33 +306,17 @@ YAML:: Sending batch to a topic +._Java-only: requires constructing `PublishBatchRequestEntry` objects programmatically_ [source,java] -------------------------------------------------------------------------------- from("direct:start") - .process(new Processor() { - @Override - public void process(Exchange exchange) throws Exception { - PublishBatchRequestEntry publishBatchRequestEntry1 = PublishBatchRequestEntry.builder() - .id("message1") - .message("This is message 1") - .build(); - - PublishBatchRequestEntry publishBatchRequestEntry2 = PublishBatchRequestEntry.builder() - .id("message2") - .message("This is message 2") - .build(); - - PublishBatchRequestEntry publishBatchRequestEntry3 = PublishBatchRequestEntry.builder() - .id("message3") - .message("This is message 3") - .build(); - - List<PublishBatchRequestEntry> pubList = new ArrayList<>(); - pubList.add(publishBatchRequestEntry1); - pubList.add(publishBatchRequestEntry2); - pubList.add(publishBatchRequestEntry3); + .process(exchange -> { + List<PublishBatchRequestEntry> pubList = List.of( + PublishBatchRequestEntry.builder().id("message1").message("This is message 1").build(), + PublishBatchRequestEntry.builder().id("message2").message("This is message 2").build(), + PublishBatchRequestEntry.builder().id("message3").message("This is message 3").build() + ); exchange.getIn().setBody(pubList); - } }) .to("aws2-sns://camel-topic?subject=The+subject+message&autoCreateTopic=true&batchEnabled=true"); --------------------------------------------------------------------------------
