From 00917ef9a1592bad4e09265020006a97949ae166 Mon Sep 17 00:00:00 2001
From: Jakub Malek <jakub.stan.malek@gmail.com>
Date: Fri, 19 Jul 2024 10:39:33 +0200
Subject: [PATCH] aws-sqs-source Kamelet extended with `maxMessagesPerPoll`,
 `waitTimeSeconds` and `visibilityTimeout` parameters (#2118)

---
 kamelets/aws-sqs-source.kamelet.yaml          | 20 +++++++++++++++++++
 .../kamelets/aws-sqs-source.kamelet.yaml      | 20 +++++++++++++++++++
 2 files changed, 40 insertions(+)

diff --git a/kamelets/aws-sqs-source.kamelet.yaml b/kamelets/aws-sqs-source.kamelet.yaml
index 48b87dc14..0de229bff 100644
--- a/kamelets/aws-sqs-source.kamelet.yaml
+++ b/kamelets/aws-sqs-source.kamelet.yaml
@@ -127,6 +127,23 @@ spec:
         description: If greedy is enabled, then the polling will happen immediately again, if the previous run polled 1 or more messages.
         type: boolean
         default: false
+      maxMessagesPerPoll:
+        title: Max messager per poll
+        description: The maximum number of messages to return. Amazon SQS never returns more messages than this value (however, fewer messages might be returned). Valid values: 1 to 10. Default: 1.
+        type: integer
+        minimum: 1
+        maximum: 10
+        default: 1
+      waitTimeSeconds:
+        title: Wait time seconds
+        description: The duration (in seconds) for which the call waits for a message to arrive in the queue before returning. If a message is available, the call returns sooner than WaitTimeSeconds. If no messages are available and the wait time expires, the call does not return a message list.
+        type: integer
+        minimum: 0
+      visibilityTimeout:
+        title: Visibility timeout
+        description: The duration (in seconds) that the received messages are hidden from subsequent retrieve requests after being retrieved by a ReceiveMessage request.
+        type: integer
+        minimum: 0
   dataTypes:
     out:
       default: text
@@ -207,5 +224,8 @@ spec:
         overrideEndpoint: "{{overrideEndpoint}}"
         delay: "{{delay}}"
         greedy: "{{greedy}}"
+        maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
+        waitTimeSeconds: "{{waitTimeSeconds}}"
+        visibilityTimeout: "{{visibilityTimeout}}"
       steps:
       - to: "kamelet:sink"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
index 48b87dc14..0de229bff 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-sqs-source.kamelet.yaml
@@ -127,6 +127,23 @@ spec:
         description: If greedy is enabled, then the polling will happen immediately again, if the previous run polled 1 or more messages.
         type: boolean
         default: false
+      maxMessagesPerPoll:
+        title: Max messager per poll
+        description: The maximum number of messages to return. Amazon SQS never returns more messages than this value (however, fewer messages might be returned). Valid values: 1 to 10. Default: 1.
+        type: integer
+        minimum: 1
+        maximum: 10
+        default: 1
+      waitTimeSeconds:
+        title: Wait time seconds
+        description: The duration (in seconds) for which the call waits for a message to arrive in the queue before returning. If a message is available, the call returns sooner than WaitTimeSeconds. If no messages are available and the wait time expires, the call does not return a message list.
+        type: integer
+        minimum: 0
+      visibilityTimeout:
+        title: Visibility timeout
+        description: The duration (in seconds) that the received messages are hidden from subsequent retrieve requests after being retrieved by a ReceiveMessage request.
+        type: integer
+        minimum: 0
   dataTypes:
     out:
       default: text
@@ -207,5 +224,8 @@ spec:
         overrideEndpoint: "{{overrideEndpoint}}"
         delay: "{{delay}}"
         greedy: "{{greedy}}"
+        maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
+        waitTimeSeconds: "{{waitTimeSeconds}}"
+        visibilityTimeout: "{{visibilityTimeout}}"
       steps:
       - to: "kamelet:sink"