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:02 UTC
[camel-kamelets] branch max-message-poll-s3 created (now cbd19761)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch max-message-poll-s3
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at cbd19761 Expose maxMessagesPerPoll in AWS S3 Source Kamelet
This branch includes the following new commits:
new cbd19761 Expose maxMessagesPerPoll in AWS S3 Source Kamelet
The 1 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.
[camel-kamelets] 01/01: Expose maxMessagesPerPoll in AWS S3 Source Kamelet
Posted by ac...@apache.org.
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}}"