[camel] 01/06: CAMEL-16171 - Add uri-endpoint-override options to all AWS2 components - AWS2-DDB Streams component

[acosentino]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git

commit 491ddb1fd9b859bf182967625ee3901a23c0ce17
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Feb 26 15:41:18 2021 +0100

    CAMEL-16171 - Add uri-endpoint-override options to all AWS2 components - 
AWS2-DDB Streams component
---
 .../aws2/ddbstream/Ddb2StreamConfiguration.java      | 20 ++++++++++++++++++++
 .../component/aws2/ddbstream/Ddb2StreamEndpoint.java |  3 +++
 2 files changed, 23 insertions(+)

diff --git 
a/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConfiguration.java
 
b/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConfiguration.java
index c79a32b..667ae32 100644
--- 
a/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConfiguration.java
+++ 
b/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamConfiguration.java
@@ -68,6 +68,10 @@ public class Ddb2StreamConfiguration implements Cloneable {
     private Integer proxyPort;
     @UriParam(defaultValue = "false", description = "If we want to trust all 
certificates in case of overriding the endpoint")
     private boolean trustAllCertificates;
+    @UriParam(defaultValue = "false", description = "Set the need for 
overidding the endpoint. This option needs to be used in combination with 
uriEndpointOverride option")
+    private boolean overrideEndpoint;
+    @UriParam(description = " Set the overriding uri endpoint. This option 
needs to be used in combination with overrideEndpoint option")
+    private String uriEndpointOverride;
 
     public DynamoDbStreamsClient getAmazonDynamoDbStreamsClient() {
         return amazonDynamoDbStreamsClient;
@@ -165,6 +169,22 @@ public class Ddb2StreamConfiguration implements Cloneable {
         this.trustAllCertificates = trustAllCertificates;
     }
 
+    public boolean isOverrideEndpoint() {
+        return overrideEndpoint;
+    }
+
+    public void setOverrideEndpoint(boolean overrideEndpoint) {
+        this.overrideEndpoint = overrideEndpoint;
+    }
+
+    public String getUriEndpointOverride() {
+        return uriEndpointOverride;
+    }
+
+    public void setUriEndpointOverride(String uriEndpointOverride) {
+        this.uriEndpointOverride = uriEndpointOverride;
+    }
+
     // *************************************************
     //
     // *************************************************
diff --git 
a/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java
 
b/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java
index 6f314ff..677db78 100644
--- 
a/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java
+++ 
b/components/camel-aws2-ddb/src/main/java/org/apache/camel/component/aws2/ddbstream/Ddb2StreamEndpoint.java
@@ -139,6 +139,9 @@ public class Ddb2StreamEndpoint extends 
ScheduledPollEndpoint {
         if (ObjectHelper.isNotEmpty(configuration.getRegion())) {
             clientBuilder = 
clientBuilder.region(Region.of(configuration.getRegion()));
         }
+        if (configuration.isOverrideEndpoint()) {
+            
clientBuilder.endpointOverride(URI.create(configuration.getUriEndpointOverride()));
+        }
         if (configuration.isTrustAllCertificates()) {
             SdkHttpClient ahc = 
ApacheHttpClient.builder().buildWithDefaults(AttributeMap
                     .builder()