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:02 UTC
[camel] 02/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 db88492d79c77e952b698e7f078b708f8311f890
Author: Andrea Cosentino <an...@gmail.com>
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())) {