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 77687b7606260404886cb7a6ef443bc2b17f323b Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Apr 20 18:04:23 2022 +0200 CAMEL-16287 - camel-aws2-sqs should use pagination for deciding which aws sqs queues it should create --- .../src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Endpoint.java | 2 +- 1 file changed, 1 insertion(+), 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 0589321229a..dca629de0a1 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,7 @@ public class Sqs2Endpoint extends ScheduledPollEndpoint implements HeaderFilterS // check whether the queue already exists boolean done = false; while (!done) { - ListQueuesResponse listQueuesResult = client.listQueues(); + ListQueuesResponse listQueuesResult = client.listQueues(ListQueuesRequest.builder().maxResults(1000).build()); for (String url : listQueuesResult.queueUrls()) { if (url.endsWith("/" + configuration.getQueueName())) {
