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/11/30 12:34:43 UTC
(camel) 01/01: AWS S3 Console more fields for consumers
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch aws-s3-console-more-fields
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 093f94a46fac4e5bc292b83778cfadc29b57dca1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Nov 30 13:28:41 2023 +0100
AWS S3 Console more fields for consumers
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../org/apache/camel/component/aws2/s3/AWS2S3Console.java | 13 ++++++++-----
1 file changed, 8 insertions(+), 5 deletions(-)
diff --git a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Console.java b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Console.java
index 44f184a4e55..50711ad24ee 100644
--- a/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Console.java
+++ b/components/camel-aws/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Console.java
@@ -43,16 +43,16 @@ public class AWS2S3Console extends AbstractDevConsole {
.filter(c -> AWS2S3Consumer.class.getName().equals(c.getClass().getName()))
.collect(Collectors.toList());
- sb.append(String.format(" %s:%s:%s:%s\n", "bucket", "accessKeys", "defaultCredentialsProvider",
- "profileCredentialsProvider"));
+ sb.append(String.format(" %s:%s:%s:%s:%s:%s:%s\n", "bucket", "accessKeys", "defaultCredentialsProvider",
+ "profileCredentialsProvider", "maxMessages", "moveAfterRead", "deleteAfterRead"));
for (Consumer c : list) {
AWS2S3Consumer nc = (AWS2S3Consumer) c;
AWS2S3Configuration conf = nc.getEndpoint().getConfiguration();
- sb.append(String.format(" %s:%s:%s:%s\n", conf.getBucketName(),
+ sb.append(String.format(" %s:%s:%s:%s:%s:%s:%s\n", conf.getBucketName(),
(!conf.isUseDefaultCredentialsProvider() && !conf.isUseProfileCredentialsProvider()),
- conf.isUseDefaultCredentialsProvider(), conf.isUseProfileCredentialsProvider()));
+ conf.isUseDefaultCredentialsProvider(), conf.isUseProfileCredentialsProvider(), nc.getMaxMessagesPerPoll(),
+ conf.isMoveAfterRead(), conf.isDeleteAfterRead()));
}
-
return sb.toString();
}
@@ -75,6 +75,9 @@ public class AWS2S3Console extends AbstractDevConsole {
jo.put("accessKeys", !conf.isUseDefaultCredentialsProvider() && !conf.isUseProfileCredentialsProvider());
jo.put("defaultCredentialsProvider", conf.isUseDefaultCredentialsProvider());
jo.put("profileCredentialsProvider", conf.isUseProfileCredentialsProvider());
+ jo.put("maxMessages", nc.getMaxMessagesPerPoll());
+ jo.put("moveAfterRead", conf.isMoveAfterRead());
+ jo.put("deleteAfterRead", conf.isDeleteAfterRead());
arr.add(jo);
}
if (!arr.isEmpty()) {