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/10/06 09:00:23 UTC

[camel-kamelets] 01/02: AWS SQS Source Kamelet: Add greedy parameter

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch 1069
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit 487c71373edb1ccdac34afa3947983b89c2b64c7
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 6 10:56:51 2022 +0200

    AWS SQS Source Kamelet: Add greedy parameter
---
 kamelets/aws-sqs-source.kamelet.yaml                           | 10 +++++++++-
 .../src/main/resources/kamelets/aws-sqs-source.kamelet.yaml    |  2 +-
 2 files changed, 10 insertions(+), 2 deletions(-)

diff --git a/kamelets/aws-sqs-source.kamelet.yaml b/kamelets/aws-sqs-source.kamelet.yaml
index 6dbe48fb..c59f0c4f 100644
--- a/kamelets/aws-sqs-source.kamelet.yaml
+++ b/kamelets/aws-sqs-source.kamelet.yaml
@@ -129,6 +129,13 @@ spec:
         description: The number of milliseconds before the next poll of the selected stream
         type: integer
         default: 500
+      greedy:
+        title: Greedy Scheduler
+        description: If greedy is enabled, then the polling will happen immediately again, if the previous run polled 1 or more messages.
+        type: boolean
+        x-descriptors:
+          - 'urn:alm:descriptor:com.tectonic.ui:checkbox'
+        default: false
   dependencies:
     - "camel:aws2-sqs"
     - "camel:kamelet"
@@ -146,6 +153,7 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
-        delay: "{{delay}}"  
+        delay: "{{delay}}"
+        greedy: "{{greedy}}"
       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 6dbe48fb..609ebf29 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
@@ -146,6 +146,6 @@ spec:
         useDefaultCredentialsProvider: "{{useDefaultCredentialsProvider}}"
         uriEndpointOverride: "{{?uriEndpointOverride}}"
         overrideEndpoint: "{{overrideEndpoint}}"
-        delay: "{{delay}}"  
+        delay: "{{delay}}" 
       steps:
       - to: "kamelet:sink"