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 2022/04/20 16:14:01 UTC
[camel] 01/02: CAMEL-16287 - camel-aws2-sqs should use pagination for deciding which aws sqs queues it should create
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 <an...@gmail.com>
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())) {