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 2023/10/16 08:44:45 UTC
[camel-kamelets] branch main updated: Expose maxMessagesPerPoll in AWS S3 Source Kamelet (#1692)
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
The following commit(s) were added to refs/heads/main by this push:
new 3a249936 Expose maxMessagesPerPoll in AWS S3 Source Kamelet (#1692)
3a249936 is described below
commit 3a24993645c4051f1d682bf557e8b99395e0a20f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Oct 16 10:44:39 2023 +0200
Expose maxMessagesPerPoll in AWS S3 Source Kamelet (#1692)
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
kamelets/aws-s3-source.kamelet.yaml | 6 ++++++
.../src/main/resources/kamelets/aws-s3-source.kamelet.yaml | 6 ++++++
2 files changed, 12 insertions(+)
diff --git a/kamelets/aws-s3-source.kamelet.yaml b/kamelets/aws-s3-source.kamelet.yaml
index c38cc990..96f2fa09 100644
--- a/kamelets/aws-s3-source.kamelet.yaml
+++ b/kamelets/aws-s3-source.kamelet.yaml
@@ -101,6 +101,11 @@ spec:
description: The number of milliseconds before the next poll of the selected bucket.
type: integer
default: 500
+ maxMessagesPerPoll:
+ title: Max Messages Per Poll
+ description: Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited.
+ type: integer
+ default: 10
dataTypes:
out:
default: binary
@@ -184,6 +189,7 @@ spec:
uriEndpointOverride: "{{?uriEndpointOverride}}"
overrideEndpoint: "{{overrideEndpoint}}"
delay: "{{delay}}"
+ maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
steps:
- process:
ref: "{{renameHeaders}}"
diff --git a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
index c38cc990..96f2fa09 100644
--- a/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
+++ b/library/camel-kamelets/src/main/resources/kamelets/aws-s3-source.kamelet.yaml
@@ -101,6 +101,11 @@ spec:
description: The number of milliseconds before the next poll of the selected bucket.
type: integer
default: 500
+ maxMessagesPerPoll:
+ title: Max Messages Per Poll
+ description: Gets the maximum number of messages as a limit to poll at each polling. Gets the maximum number of messages as a limit to poll at each polling. The default value is 10. Use 0 or a negative number to set it as unlimited.
+ type: integer
+ default: 10
dataTypes:
out:
default: binary
@@ -184,6 +189,7 @@ spec:
uriEndpointOverride: "{{?uriEndpointOverride}}"
overrideEndpoint: "{{overrideEndpoint}}"
delay: "{{delay}}"
+ maxMessagesPerPoll: "{{maxMessagesPerPoll}}"
steps:
- process:
ref: "{{renameHeaders}}"