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 eab6901bac66d34fff47471860ae83da0e5f7a93
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Jul 21 07:48:56 2020 +0200
CAMEL-15310 - AWS* - Support for more than 1 client in the registry -
Camel-AWS2-S3
---
.../aws2/s3/AWS2S3ComponentConfigurer.java | 5 ++
.../aws2/s3/AWS2S3EndpointConfigurer.java | 5 ++
.../apache/camel/component/aws2/s3/aws2-s3.json | 2 +
.../src/main/docs/aws2-s3-component.adoc | 6 +-
.../camel/component/aws2/s3/AWS2S3Component.java | 4 +-
.../component/aws2/s3/AWS2S3Configuration.java | 15 ++++
.../aws2/s3/S3ComponentConfigurationTest.java | 26 +++++++
.../dsl/Aws2S3ComponentBuilderFactory.java | 16 ++++
.../builder/endpoint/StaticEndpointBuilders.java | 8 +-
.../endpoint/dsl/AWS2S3EndpointBuilderFactory.java | 90 ++++++++++++++++++++++
10 files changed, 170 insertions(+), 7 deletions(-)
diff --git
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
index 19075a6..8740b99 100644
---
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
+++
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3ComponentConfigurer.java
@@ -32,6 +32,8 @@ public class AWS2S3ComponentConfigurer extends
PropertyConfigurerSupport impleme
case "amazonS3Client":
getOrCreateConfiguration(target).setAmazonS3Client(property(camelContext,
software.amazon.awssdk.services.s3.S3Client.class, value)); return true;
case "autocreatebucket":
case "autoCreateBucket":
getOrCreateConfiguration(target).setAutoCreateBucket(property(camelContext,
boolean.class, value)); return true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
getOrCreateConfiguration(target).setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "autoclosebody":
case "autocloseBody":
getOrCreateConfiguration(target).setAutocloseBody(property(camelContext,
boolean.class, value)); return true;
case "awskmskeyid":
@@ -108,6 +110,7 @@ public class AWS2S3ComponentConfigurer extends
PropertyConfigurerSupport impleme
answer.put("accessKey", java.lang.String.class);
answer.put("amazonS3Client",
software.amazon.awssdk.services.s3.S3Client.class);
answer.put("autoCreateBucket", boolean.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("autocloseBody", boolean.class);
answer.put("awsKMSKeyId", java.lang.String.class);
answer.put("basicPropertyBinding", boolean.class);
@@ -157,6 +160,8 @@ public class AWS2S3ComponentConfigurer extends
PropertyConfigurerSupport impleme
case "amazonS3Client": return
getOrCreateConfiguration(target).getAmazonS3Client();
case "autocreatebucket":
case "autoCreateBucket": return
getOrCreateConfiguration(target).isAutoCreateBucket();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
getOrCreateConfiguration(target).isAutoDiscoverClient();
case "autoclosebody":
case "autocloseBody": return
getOrCreateConfiguration(target).isAutocloseBody();
case "awskmskeyid":
diff --git
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
index d18bc07..f12971f 100644
---
a/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
+++
b/components/camel-aws2-s3/src/generated/java/org/apache/camel/component/aws2/s3/AWS2S3EndpointConfigurer.java
@@ -25,6 +25,8 @@ public class AWS2S3EndpointConfigurer extends
PropertyConfigurerSupport implemen
case "amazonS3Client":
target.getConfiguration().setAmazonS3Client(property(camelContext,
software.amazon.awssdk.services.s3.S3Client.class, value)); return true;
case "autocreatebucket":
case "autoCreateBucket":
target.getConfiguration().setAutoCreateBucket(property(camelContext,
boolean.class, value)); return true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
target.getConfiguration().setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "autoclosebody":
case "autocloseBody":
target.getConfiguration().setAutocloseBody(property(camelContext,
boolean.class, value)); return true;
case "awskmskeyid":
@@ -138,6 +140,7 @@ public class AWS2S3EndpointConfigurer extends
PropertyConfigurerSupport implemen
answer.put("accessKey", java.lang.String.class);
answer.put("amazonS3Client",
software.amazon.awssdk.services.s3.S3Client.class);
answer.put("autoCreateBucket", boolean.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("autocloseBody", boolean.class);
answer.put("awsKMSKeyId", java.lang.String.class);
answer.put("backoffErrorThreshold", int.class);
@@ -207,6 +210,8 @@ public class AWS2S3EndpointConfigurer extends
PropertyConfigurerSupport implemen
case "amazonS3Client": return
target.getConfiguration().getAmazonS3Client();
case "autocreatebucket":
case "autoCreateBucket": return
target.getConfiguration().isAutoCreateBucket();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
target.getConfiguration().isAutoDiscoverClient();
case "autoclosebody":
case "autocloseBody": return
target.getConfiguration().isAutocloseBody();
case "awskmskeyid":
diff --git
a/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
b/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
index acfa6d0..1d06c92 100644
---
a/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
+++
b/components/camel-aws2-s3/src/generated/resources/org/apache/camel/component/aws2/s3/aws2-s3.json
@@ -23,6 +23,7 @@
"componentProperties": {
"amazonS3Client": { "kind": "property", "displayName": "Amazon S3 Client",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.s3.S3Client", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry." },
"autoCreateBucket": { "kind": "property", "displayName": "Auto Create
Bucket", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Setting the autocreation of the bucket" },
+ "autoDiscoverClient": { "kind": "property", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the regis [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.s3.AWS2S3Configuration",
"deprecated": false, "secret": false, "description": "The component
configuration" },
"overrideEndpoint": { "kind": "property", "displayName": "Override
Endpoint", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "false", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Set the need for overidding the endpoint. This
option needs to be used in combination with uriEndpointOverride option" },
"pojoRequest": { "kind": "property", "displayName": "Pojo Request",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
"false", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If we want to use a POJO request as body or
not" },
@@ -65,6 +66,7 @@
"bucketNameOrArn": { "kind": "path", "displayName": "Bucket Name Or Arn",
"group": "common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "secret":
false, "description": "Bucket name or ARN" },
"amazonS3Client": { "kind": "parameter", "displayName": "Amazon S3
Client", "group": "common", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.services.s3.S3Client", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry." },
"autoCreateBucket": { "kind": "parameter", "displayName": "Auto Create
Bucket", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Setting the autocreation of the bucket" },
+ "autoDiscoverClient": { "kind": "parameter", "displayName": "Auto Discover
Client", "group": "common", "label": "common", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "true", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the regi [...]
"overrideEndpoint": { "kind": "parameter", "displayName": "Override
Endpoint", "group": "common", "label": "", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": "false", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "Set the need for overidding the endpoint. This
option needs to be used in combination with uriEndpointOverride option" },
"pojoRequest": { "kind": "parameter", "displayName": "Pojo Request",
"group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "secret": false, "defaultValue":
"false", "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "If we want to use a POJO request as body or
not" },
"policy": { "kind": "parameter", "displayName": "Policy", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.s3.AWS2S3Configuration", "configurationField":
"configuration", "description": "The policy for this queue to set in the
com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method." },
diff --git a/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
b/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
index b873ea0..a467d80 100644
--- a/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
+++ b/components/camel-aws2-s3/src/main/docs/aws2-s3-component.adoc
@@ -46,7 +46,7 @@
from("aws2-s3://helloBucket?accessKey=yourAccessKey&secretKey=yourSecretKey&pref
// component options: START
-The AWS 2 S3 Storage Service component supports 39 options, which are listed
below.
+The AWS 2 S3 Storage Service component supports 40 options, which are listed
below.
@@ -55,6 +55,7 @@ The AWS 2 S3 Storage Service component supports 39 options,
which are listed bel
| Name | Description | Default | Type
| *amazonS3Client* (common) | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | | S3Client
| *autoCreateBucket* (common) | Setting the autocreation of the bucket | true
| boolean
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *configuration* (common) | The component configuration | |
AWS2S3Configuration
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This
option needs to be used in combination with uriEndpointOverride option | false
| boolean
| *pojoRequest* (common) | If we want to use a POJO request as body or not |
false | boolean
@@ -124,7 +125,7 @@ with the following path and query parameters:
|===
-=== Query Parameters (59 parameters):
+=== Query Parameters (60 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
@@ -132,6 +133,7 @@ with the following path and query parameters:
| Name | Description | Default | Type
| *amazonS3Client* (common) | Reference to a
com.amazonaws.services.s3.AmazonS3 in the registry. | | S3Client
| *autoCreateBucket* (common) | Setting the autocreation of the bucket | true
| boolean
+| *autoDiscoverClient* (common) | Setting the autoDiscoverClient mechanism, if
true, the component will look for a client instance in the registry
automatically otherwise it will skip that checking. | true | boolean
| *overrideEndpoint* (common) | Set the need for overidding the endpoint. This
option needs to be used in combination with uriEndpointOverride option | false
| boolean
| *pojoRequest* (common) | If we want to use a POJO request as body or not |
false | boolean
| *policy* (common) | The policy for this queue to set in the
com.amazonaws.services.s3.AmazonS3#setBucketPolicy() method. | | String
diff --git
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Component.java
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Component.java
index c4fe75e..2d9b643 100644
---
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Component.java
+++
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Component.java
@@ -60,7 +60,9 @@ public class AWS2S3Component extends DefaultComponent {
configuration.setBucketName(remaining);
AWS2S3Endpoint endpoint = new AWS2S3Endpoint(uri, this, configuration);
setProperties(endpoint, parameters);
- checkAndSetRegistryClient(configuration, endpoint);
+ if (endpoint.getConfiguration().isAutoDiscoverClient()) {
+ checkAndSetRegistryClient(configuration, endpoint);
+ }
if (!configuration.isUseIAMCredentials() &&
configuration.getAmazonS3Client() == null && (configuration.getAccessKey() ==
null || configuration.getSecretKey() == null)) {
throw new IllegalArgumentException("useIAMCredentials is set to
false, AmazonS3Client or accessKey and secretKey must be specified");
}
diff --git
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
index b16d35a..91d9fe17 100644
---
a/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
+++
b/components/camel-aws2-s3/src/main/java/org/apache/camel/component/aws2/s3/AWS2S3Configuration.java
@@ -97,6 +97,8 @@ public class AWS2S3Configuration implements Cloneable {
private String uriEndpointOverride;
@UriParam(defaultValue = "false")
private boolean pojoRequest;
+ @UriParam(label = "common", defaultValue = "true")
+ private boolean autoDiscoverClient = true;
public long getPartSize() {
return partSize;
@@ -534,6 +536,19 @@ public class AWS2S3Configuration implements Cloneable {
public void setTrustAllCertificates(boolean trustAllCertificates) {
this.trustAllCertificates = trustAllCertificates;
}
+
+ public boolean isAutoDiscoverClient() {
+ return autoDiscoverClient;
+ }
+
+ /**
+ * Setting the autoDiscoverClient mechanism, if true, the component will
+ * look for a client instance in the registry automatically otherwise it
+ * will skip that checking.
+ */
+ public void setAutoDiscoverClient(boolean autoDiscoverClient) {
+ this.autoDiscoverClient = autoDiscoverClient;
+ }
public AWS2S3Configuration copy() {
try {
diff --git
a/components/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentConfigurationTest.java
b/components/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentConfigurationTest.java
index 1016153..13096e4 100644
---
a/components/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentConfigurationTest.java
+++
b/components/camel-aws2-s3/src/test/java/org/apache/camel/component/aws2/s3/S3ComponentConfigurationTest.java
@@ -19,7 +19,11 @@ package org.apache.camel.component.aws2.s3;
import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Test;
+import software.amazon.awssdk.services.s3.S3Client;
+
import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertNotSame;
+import static org.junit.jupiter.api.Assertions.assertSame;
import static org.junit.jupiter.api.Assertions.assertTrue;
public class S3ComponentConfigurationTest extends CamelTestSupport {
@@ -32,4 +36,26 @@ public class S3ComponentConfigurationTest extends
CamelTestSupport {
assertTrue(endpoint.getConfiguration().isOverrideEndpoint());
assertEquals(endpoint.getConfiguration().getUriEndpointOverride(),
"http://localhost:4572";);
}
+
+ @Test
+ public void createEndpointWithCredentialsAndClientExistInRegistry() throws
Exception {
+ S3Client client = S3Client.builder().build();
+ context.getRegistry().bind("amazonS3Client", client);
+ AWS2S3Component component = context.getComponent("aws2-s3",
AWS2S3Component.class);
+ AWS2S3Endpoint endpoint =
(AWS2S3Endpoint)component.createEndpoint("aws2-s3://MyBucket?accessKey=RAW(XXX)&secretKey=RAW(XXX)&autoDiscoverClient=false");
+
+ assertEquals("MyBucket", endpoint.getConfiguration().getBucketName());
+ assertNotSame(client, endpoint.getConfiguration().getAmazonS3Client());
+ }
+
+ @Test
+ public void
createEndpointWithCredentialsAndClientExistInRegistryWithAutodiscover() throws
Exception {
+ S3Client client = S3Client.builder().build();
+ context.getRegistry().bind("amazonS3Client", client);
+ AWS2S3Component component = context.getComponent("aws2-s3",
AWS2S3Component.class);
+ AWS2S3Endpoint endpoint =
(AWS2S3Endpoint)component.createEndpoint("aws2-s3://MyBucket?accessKey=RAW(XXX)&secretKey=RAW(XXX)");
+
+ assertEquals("MyBucket", endpoint.getConfiguration().getBucketName());
+ assertSame(client, endpoint.getConfiguration().getAmazonS3Client());
+ }
}
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
index a7daa69..8e6f3e9 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2S3ComponentBuilderFactory.java
@@ -76,6 +76,21 @@ public interface Aws2S3ComponentBuilderFactory {
return this;
}
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default Aws2S3ComponentBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* The component configuration.
*
* The option is a:
@@ -601,6 +616,7 @@ public interface Aws2S3ComponentBuilderFactory {
switch (name) {
case "amazonS3Client": getOrCreateConfiguration((AWS2S3Component)
component).setAmazonS3Client((software.amazon.awssdk.services.s3.S3Client)
value); return true;
case "autoCreateBucket":
getOrCreateConfiguration((AWS2S3Component)
component).setAutoCreateBucket((boolean) value); return true;
+ case "autoDiscoverClient":
getOrCreateConfiguration((AWS2S3Component)
component).setAutoDiscoverClient((boolean) value); return true;
case "configuration": ((AWS2S3Component)
component).setConfiguration((org.apache.camel.component.aws2.s3.AWS2S3Configuration)
value); return true;
case "overrideEndpoint":
getOrCreateConfiguration((AWS2S3Component)
component).setOverrideEndpoint((boolean) value); return true;
case "pojoRequest": getOrCreateConfiguration((AWS2S3Component)
component).setPojoRequest((boolean) value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
index aa0805c..5031310 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/StaticEndpointBuilders.java
@@ -1417,7 +1417,7 @@ public class StaticEndpointBuilders {
*
* @param path //bucketNameOrArn
*/
- public static
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3EndpointBuilder
aws2S3(
+ static
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3EndpointBuilder
aws2S3(
String path) {
return
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.endpointBuilder("aws2-s3",
path);
}
@@ -1439,7 +1439,7 @@ public class StaticEndpointBuilders {
* instead of the default name
* @param path //bucketNameOrArn
*/
- public static
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3EndpointBuilder
aws2S3(
+ static
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3EndpointBuilder
aws2S3(
String componentName,
String path) {
return
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.endpointBuilder(componentName,
path);
@@ -2160,7 +2160,7 @@ public class StaticEndpointBuilders {
*
* @param path //bucketNameOrArn
*/
- static
org.apache.camel.builder.endpoint.dsl.S3EndpointBuilderFactory.S3EndpointBuilder
awsS3(
+ public static
org.apache.camel.builder.endpoint.dsl.S3EndpointBuilderFactory.S3EndpointBuilder
awsS3(
String path) {
return
org.apache.camel.builder.endpoint.dsl.S3EndpointBuilderFactory.endpointBuilder("aws-s3",
path);
}
@@ -2181,7 +2181,7 @@ public class StaticEndpointBuilders {
* instead of the default name
* @param path //bucketNameOrArn
*/
- static
org.apache.camel.builder.endpoint.dsl.S3EndpointBuilderFactory.S3EndpointBuilder
awsS3(
+ public static
org.apache.camel.builder.endpoint.dsl.S3EndpointBuilderFactory.S3EndpointBuilder
awsS3(
String componentName,
String path) {
return
org.apache.camel.builder.endpoint.dsl.S3EndpointBuilderFactory.endpointBuilder(componentName,
path);
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
index 041f9ad..f7aec1e 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/AWS2S3EndpointBuilderFactory.java
@@ -101,6 +101,36 @@ public interface AWS2S3EndpointBuilderFactory {
return this;
}
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default AWS2S3EndpointConsumerBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default AWS2S3EndpointConsumerBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Set the need for overidding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
@@ -1308,6 +1338,36 @@ public interface AWS2S3EndpointBuilderFactory {
return this;
}
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default AWS2S3EndpointProducerBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default AWS2S3EndpointProducerBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Set the need for overidding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
@@ -1938,6 +1998,36 @@ public interface AWS2S3EndpointBuilderFactory {
return this;
}
/**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default AWS2S3EndpointBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
+ * Setting the autoDiscoverClient mechanism, if true, the component
will
+ * look for a client instance in the registry automatically otherwise
it
+ * will skip that checking.
+ *
+ * The option will be converted to a <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ */
+ default AWS2S3EndpointBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Set the need for overidding the endpoint. This option needs to be
* used in combination with uriEndpointOverride option.
*
