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"