This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch camel-3.14.x in repository https://gitbox.apache.org/repos/asf/camel.git
commit db88492d79c77e952b698e7f078b708f8311f890 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Apr 20 18:12:08 2022 +0200 CAMEL-16287 - camel-aws2-sqs should use pagination for deciding which aws sqs queues it should create --- .../main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java index dca629de0a1..85d5469520b 100644 --- a/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java +++ b/components/camel-aws/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java @@ -168,7 +168,8 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint implements HeaderFilterS // check whether the queue already exists boolean done = false; while (!done) { - ListQueuesResponse listQueuesResult = client.listQueues(ListQueuesRequest.builder().maxResults(1000).build()); + ListQueuesResponse listQueuesResult + = client.listQueues(ListQueuesRequest.builder().maxResults(1000).build()); for (String url : listQueuesResult.queueUrls()) { if (url.endsWith("/" + configuration.getQueueName())) {
