aws-sqs-source Kamelet extended with maxMessagesPerPoll, `waitTimeS…

…econds` and `visibilityTimeout` parameters (apache#2118)
jakubmalek · Jul 19, 2024 · 00917ef · 00917ef
1 parent b03bd19
commit 00917ef
Show file tree

Hide file tree

Showing 2 changed files with 40 additions and 0 deletions.
diff --git 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
@@ -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"