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 <[email protected]> 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"
