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:29:03 UTC
[camel-kamelets] 01/01: Expose maxMessagesPerPoll in AWS S3 Source Kamelet
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch max-message-poll-s3
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit cbd19761da2aeee18831311f5e578d61734b15f5
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Oct 16 10:27:56 2023 +0200
Expose maxMessagesPerPoll in AWS S3 Source Kamelet
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}}"