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.git

commit 860fb543f2261e2be79951b4b070c21f9e11f6a1
Author: Andrea Cosentino <[email protected]>
AuthorDate: Fri Jun 16 10:14:01 2023 +0200

    CAMEL-19159 - Camel-AWS: Support Profile Credential provider as 
configuration - AWS Kinesis
    
    Signed-off-by: Andrea Cosentino <[email protected]>
---
 .../aws2/kinesis/Kinesis2Configuration.java        | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)

diff --git 
a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
 
b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
index db57da4206a..43d4c26024c 100644
--- 
a/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
+++ 
b/components/camel-aws/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
@@ -82,6 +82,13 @@ public class Kinesis2Configuration implements Cloneable {
                             +
                             "static credentials to be passed in.")
     private boolean useDefaultCredentialsProvider;
+    @UriParam(label = "common", defaultValue = "false",
+              description = "Set whether the Kinesis client should expect to 
load credentials through a profile credentials provider.")
+    private boolean useProfileCredentialsProvider;
+    @UriParam(label = "common",
+              description =  "If using a profile credentials provider this 
parameter will set the profile name.")
+    private String profileCredentialsName;
+
 
     public KinesisClient getAmazonKinesisClient() {
         return amazonKinesisClient;
@@ -227,6 +234,21 @@ public class Kinesis2Configuration implements Cloneable {
         this.useDefaultCredentialsProvider = useDefaultCredentialsProvider;
     }
 
+    public boolean isUseProfileCredentialsProvider() {
+        return useProfileCredentialsProvider;
+    }
+
+    public void setUseProfileCredentialsProvider(boolean 
useProfileCredentialsProvider) {
+        this.useProfileCredentialsProvider = useProfileCredentialsProvider;
+    }
+
+    public String getProfileCredentialsName() {
+        return profileCredentialsName;
+    }
+
+    public void setProfileCredentialsName(String profileCredentialsName) {
+        this.profileCredentialsName = profileCredentialsName;
+    }
     // *************************************************
     //
     // *************************************************

Reply via email to