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 2021/02/26 15:42:57 UTC
[camel] 01/06: CAMEL-16171 - Add uri-endpoint-override options to
all AWS2 components - AWS2-DDB Streams component
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 <an...@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()