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:08:44 UTC
[camel-kamelets] branch main updated (012c973b -> edf50dad)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
from 012c973b Use filtering as mode for duplicating headers bean in AWS S3 Source
new d7e6ea2c AWS SQS Source Kamelet: Add greedy parameter
new 8d5d9294 AWS SQS Source Kamelet: Add greedy parameter
new edf50dad AWS SQS Source Kamelet: Add greedy parameter
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
kamelets/aws-sqs-source.kamelet.yaml | 10 +++++++++-
.../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 +-
.../src/main/resources/kamelets/aws-sqs-source.kamelet.yaml | 10 +++++++++-
3 files changed, 19 insertions(+), 3 deletions(-)
[camel-kamelets] 02/03: AWS SQS Source Kamelet: Add greedy parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 8d5d9294a2039451050cd18c324a506fcf8f8481
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 6 10:57:58 2022 +0200
AWS SQS Source Kamelet: Add greedy parameter
---
.../src/main/resources/kamelets/aws-sqs-source.kamelet.yaml | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
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 609ebf29..c59f0c4f 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
@@ -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"
[camel-kamelets] 01/03: AWS SQS Source Kamelet: Add greedy parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit d7e6ea2cd80bda541b252cf3440492f2d7e46df9
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"
[camel-kamelets] 03/03: AWS SQS Source Kamelet: Add greedy parameter
Posted by ac...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit edf50dad43c11445e598382f5853dc4df9d96fbb
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 6 11:02:27 2022 +0200
AWS SQS Source Kamelet: Add greedy parameter
---
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
index 2eff5cde..31d21bbb 100644
--- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
+++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
@@ -54,7 +54,7 @@ public class KameletsCatalogTest {
@Test
void testGetKameletsDefinition() throws Exception {
JSONSchemaProps props = catalog.getKameletDefinition("aws-sqs-source");
- assertEquals(13, props.getProperties().keySet().size());
+ assertEquals(14, props.getProperties().keySet().size());
assertTrue(props.getProperties().keySet().contains("queueNameOrArn"));
}