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/03/03 13:26:38 UTC
[camel] 01/05: CAMEL-16171 - Add uri-endpoint-override options to
all AWS2 components - AWS2-SQS 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 ea7eb7b3512fb0dbee2c8cf77dacfacaf4315dff
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Mar 3 13:51:30 2021 +0100
CAMEL-16171 - Add uri-endpoint-override options to all AWS2 components - AWS2-SQS component
---
.../component/aws2/sqs/Sqs2Configuration.java | 27 ++++++++++++++++++++++
1 file changed, 27 insertions(+)
diff --git a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
index c9c8ed4..44218ad 100644
--- a/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
+++ b/components/camel-aws2-sqs/src/main/java/org/apache/camel/component/aws2/sqs/Sqs2Configuration.java
@@ -51,6 +51,10 @@ public class Sqs2Configuration implements Cloneable {
private boolean autoCreateQueue = true;
@UriParam(defaultValue = "false")
private boolean trustAllCertificates;
+ @UriParam(defaultValue = "false")
+ private boolean overrideEndpoint;
+ @UriParam
+ private String uriEndpointOverride;
// consumer properties
@UriParam(label = "consumer", defaultValue = "true")
@@ -585,6 +589,29 @@ public class Sqs2Configuration implements Cloneable {
this.batchSeparator = batchSeparator;
}
+ public boolean isOverrideEndpoint() {
+ return overrideEndpoint;
+ }
+
+ /**
+ * Set the need for overidding the endpoint. This option needs to be used in combination with uriEndpointOverride
+ * option
+ */
+ public void setOverrideEndpoint(boolean overrideEndpoint) {
+ this.overrideEndpoint = overrideEndpoint;
+ }
+
+ public String getUriEndpointOverride() {
+ return uriEndpointOverride;
+ }
+
+ /**
+ * Set the overriding uri endpoint. This option needs to be used in combination with overrideEndpoint option
+ */
+ public void setUriEndpointOverride(String uriEndpointOverride) {
+ this.uriEndpointOverride = uriEndpointOverride;
+ }
+
// *************************************************
//
// *************************************************