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/06/09 16:13:19 UTC
[camel] 01/02: CAMEL-19159 - Camel-AWS: Support Profile Credential provider as configuration - AWS Lambda
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 95380d2313c896b7752597b98023139ae7f188af
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Jun 9 18:10:19 2023 +0200
CAMEL-19159 - Camel-AWS: Support Profile Credential provider as configuration - AWS Lambda
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../impl/Lambda2ClientIAMProfileOptimizedImpl.java | 19 ++-----------------
1 file changed, 2 insertions(+), 17 deletions(-)
diff --git a/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/client/impl/Lambda2ClientIAMProfileOptimizedImpl.java b/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/client/impl/Lambda2ClientIAMProfileOptimizedImpl.java
index 90e064b415f..b8cd4313e34 100644
--- a/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/client/impl/Lambda2ClientIAMProfileOptimizedImpl.java
+++ b/components/camel-aws/camel-aws2-lambda/src/main/java/org/apache/camel/component/aws2/lambda/client/impl/Lambda2ClientIAMProfileOptimizedImpl.java
@@ -49,38 +49,23 @@ public class Lambda2ClientIAMProfileOptimizedImpl implements Lambda2InternalClie
this.configuration = configuration;
}
- /**
- * Getting the Lambda aws client that is used.
- *
- * @return Amazon Lambda Client.
- */
@Override
public LambdaClient getLambdaClient() {
LambdaClient client = null;
LambdaClientBuilder clientBuilder = LambdaClient.builder();
ProxyConfiguration.Builder proxyConfig = null;
ApacheHttpClient.Builder httpClientBuilder = null;
- boolean isClientConfigFound = false;
if (ObjectHelper.isNotEmpty(configuration.getProxyHost()) && ObjectHelper.isNotEmpty(configuration.getProxyPort())) {
proxyConfig = ProxyConfiguration.builder();
URI proxyEndpoint = URI.create(configuration.getProxyProtocol() + "://" + configuration.getProxyHost() + ":"
- + configuration.getProxyPort());
+ + configuration.getProxyPort());
proxyConfig.endpoint(proxyEndpoint);
httpClientBuilder = ApacheHttpClient.builder().proxyConfiguration(proxyConfig.build());
- isClientConfigFound = true;
+ clientBuilder = clientBuilder.httpClientBuilder(httpClientBuilder);
}
if (configuration.getProfileCredentialsName() != null) {
- if (isClientConfigFound) {
clientBuilder = clientBuilder.httpClientBuilder(httpClientBuilder)
.credentialsProvider(ProfileCredentialsProvider.create(configuration.getProfileCredentialsName()));
- } else {
- clientBuilder = clientBuilder
- .credentialsProvider(ProfileCredentialsProvider.create(configuration.getProfileCredentialsName()));
- }
- } else {
- if (!isClientConfigFound) {
- clientBuilder = clientBuilder.httpClientBuilder(httpClientBuilder);
- }
}
if (ObjectHelper.isNotEmpty(configuration.getRegion())) {
clientBuilder = clientBuilder.region(Region.of(configuration.getRegion()));