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 812c7aebcedea9b7b3702bd31ccdf39563350d22
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Thu Jul 23 08:58:13 2020 +0200
CAMEL-15310 - AWS* - Support for more than 1 client in the registry -
Camel-AWS2-Kinesis
---
.../aws2/kinesis/Kinesis2ComponentConfigurer.java | 5 ++
.../aws2/kinesis/Kinesis2EndpointConfigurer.java | 5 ++
.../camel/component/aws2/kinesis/aws2-kinesis.json | 2 +
.../src/main/docs/aws2-kinesis-component.adoc | 6 +-
.../component/aws2/kinesis/Kinesis2Component.java | 4 +-
.../aws2/kinesis/Kinesis2Configuration.java | 11 +++
.../kinesis/KinesisComponentConfigurationTest.java | 11 +++
.../dsl/Aws2KinesisComponentBuilderFactory.java | 16 ++++
.../builder/endpoint/StaticEndpointBuilders.java | 8 +-
.../dsl/Kinesis2EndpointBuilderFactory.java | 90 ++++++++++++++++++++++
10 files changed, 151 insertions(+), 7 deletions(-)
diff --git
a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java
b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java
index 5c8d827..0d96723 100644
---
a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java
+++
b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2ComponentConfigurer.java
@@ -30,6 +30,8 @@ public class Kinesis2ComponentConfigurer extends
PropertyConfigurerSupport imple
case "accessKey":
getOrCreateConfiguration(target).setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
case "amazonkinesisclient":
case "amazonKinesisClient":
getOrCreateConfiguration(target).setAmazonKinesisClient(property(camelContext,
software.amazon.awssdk.services.kinesis.KinesisClient.class, value)); return
true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
getOrCreateConfiguration(target).setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "basicpropertybinding":
case "basicPropertyBinding":
target.setBasicPropertyBinding(property(camelContext, boolean.class, value));
return true;
case "bridgeerrorhandler":
@@ -67,6 +69,7 @@ public class Kinesis2ComponentConfigurer extends
PropertyConfigurerSupport imple
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
answer.put("amazonKinesisClient",
software.amazon.awssdk.services.kinesis.KinesisClient.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("bridgeErrorHandler", boolean.class);
answer.put("configuration",
org.apache.camel.component.aws2.kinesis.Kinesis2Configuration.class);
@@ -93,6 +96,8 @@ public class Kinesis2ComponentConfigurer extends
PropertyConfigurerSupport imple
case "accessKey": return
getOrCreateConfiguration(target).getAccessKey();
case "amazonkinesisclient":
case "amazonKinesisClient": return
getOrCreateConfiguration(target).getAmazonKinesisClient();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
getOrCreateConfiguration(target).isAutoDiscoverClient();
case "basicpropertybinding":
case "basicPropertyBinding": return target.isBasicPropertyBinding();
case "bridgeerrorhandler":
diff --git
a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java
b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java
index c962530..81df8e6 100644
---
a/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java
+++
b/components/camel-aws2-kinesis/src/generated/java/org/apache/camel/component/aws2/kinesis/Kinesis2EndpointConfigurer.java
@@ -23,6 +23,8 @@ public class Kinesis2EndpointConfigurer extends
PropertyConfigurerSupport implem
case "accessKey":
target.getConfiguration().setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
case "amazonkinesisclient":
case "amazonKinesisClient":
target.getConfiguration().setAmazonKinesisClient(property(camelContext,
software.amazon.awssdk.services.kinesis.KinesisClient.class, value)); return
true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
target.getConfiguration().setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "backofferrorthreshold":
case "backoffErrorThreshold":
target.setBackoffErrorThreshold(property(camelContext, int.class, value));
return true;
case "backoffidlethreshold":
@@ -93,6 +95,7 @@ public class Kinesis2EndpointConfigurer extends
PropertyConfigurerSupport implem
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
answer.put("amazonKinesisClient",
software.amazon.awssdk.services.kinesis.KinesisClient.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("backoffErrorThreshold", int.class);
answer.put("backoffIdleThreshold", int.class);
answer.put("backoffMultiplier", int.class);
@@ -137,6 +140,8 @@ public class Kinesis2EndpointConfigurer extends
PropertyConfigurerSupport implem
case "accessKey": return target.getConfiguration().getAccessKey();
case "amazonkinesisclient":
case "amazonKinesisClient": return
target.getConfiguration().getAmazonKinesisClient();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
target.getConfiguration().isAutoDiscoverClient();
case "backofferrorthreshold":
case "backoffErrorThreshold": return target.getBackoffErrorThreshold();
case "backoffidlethreshold":
diff --git
a/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json
b/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json
index 6cc8fe8..492c7ec 100644
---
a/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json
+++
b/components/camel-aws2-kinesis/src/generated/resources/org/apache/camel/component/aws2/kinesis/aws2-kinesis.json
@@ -22,6 +22,7 @@
},
"componentProperties": {
"amazonKinesisClient": { "kind": "property", "displayName": "Amazon
Kinesis Client", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "software.amazon.awssdk.services.kinesis.KinesisClient",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Amazon Kinesis client to
use for all requests for this endpoint" },
+ "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.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in th [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"deprecated": false, "secret": false, "description": "Component configuration"
},
"proxyHost": { "kind": "property", "displayName": "Proxy Host", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the Kinesis client" },
"proxyPort": { "kind": "property", "displayName": "Proxy Port", "group":
"common", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the Kinesis client" },
@@ -42,6 +43,7 @@
"properties": {
"streamName": { "kind": "path", "displayName": "Stream Name", "group":
"common", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "secret":
false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Name of the stream" },
"amazonKinesisClient": { "kind": "parameter", "displayName": "Amazon
Kinesis Client", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "software.amazon.awssdk.services.kinesis.KinesisClient",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Amazon Kinesis client to
use for all requests for this endpoint" },
+ "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.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in t [...]
"proxyHost": { "kind": "parameter", "displayName": "Proxy Host", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "To define a proxy host
when instantiating the Kinesis client" },
"proxyPort": { "kind": "parameter", "displayName": "Proxy Port", "group":
"common", "label": "", "required": false, "type": "integer", "javaType":
"java.lang.Integer", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the Kinesis client" },
"proxyProtocol": { "kind": "parameter", "displayName": "Proxy Protocol",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "software.amazon.awssdk.core.Protocol", "enum": [ "HTTP", "HTTPS"
], "deprecated": false, "secret": false, "defaultValue": "HTTPS",
"configurationClass":
"org.apache.camel.component.aws2.kinesis.Kinesis2Configuration",
"configurationField": "configuration", "description": "To define a proxy
protocol when instantiating the Kinesis cl [...]
diff --git
a/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc
b/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc
index 1b82b68..910efb6 100644
--- a/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc
+++ b/components/camel-aws2-kinesis/src/main/docs/aws2-kinesis-component.adoc
@@ -42,7 +42,7 @@ The stream needs to be created prior to it being used. +
// component options: START
-The AWS 2 Kinesis component supports 17 options, which are listed below.
+The AWS 2 Kinesis component supports 18 options, which are listed below.
@@ -50,6 +50,7 @@ The AWS 2 Kinesis component supports 17 options, which are
listed below.
|===
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all
requests for this endpoint | | KinesisClient
+| *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) | Component configuration | | Kinesis2Configuration
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis
client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis
client | | Integer
@@ -94,13 +95,14 @@ with the following path and query parameters:
|===
-=== Query Parameters (35 parameters):
+=== Query Parameters (36 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all
requests for this endpoint | | KinesisClient
+| *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
| *proxyHost* (common) | To define a proxy host when instantiating the Kinesis
client | | String
| *proxyPort* (common) | To define a proxy port when instantiating the Kinesis
client | | Integer
| *proxyProtocol* (common) | To define a proxy protocol when instantiating the
Kinesis client. The value can be one of: HTTP, HTTPS | HTTPS | Protocol
diff --git
a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Component.java
b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Component.java
index bcc779e..93fabab 100644
---
a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Component.java
+++
b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Component.java
@@ -48,7 +48,9 @@ public class Kinesis2Component extends DefaultComponent {
configuration.setStreamName(remaining);
Kinesis2Endpoint endpoint = new Kinesis2Endpoint(uri, configuration,
this);
setProperties(endpoint, parameters);
- checkAndSetRegistryClient(configuration);
+ if (endpoint.getConfiguration().isAutoDiscoverClient()) {
+ checkAndSetRegistryClient(configuration);
+ }
if (configuration.getAmazonKinesisClient() == null &&
(configuration.getAccessKey() == null || configuration.getSecretKey() == null))
{
throw new IllegalArgumentException("amazonKinesisClient or
accessKey and secretKey must be specified");
}
diff --git
a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
index ca5e668..935b42f 100644
---
a/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
+++
b/components/camel-aws2-kinesis/src/main/java/org/apache/camel/component/aws2/kinesis/Kinesis2Configuration.java
@@ -61,6 +61,9 @@ public class Kinesis2Configuration 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(label = "common", defaultValue = "true", description = "Setting
the autoDiscoverClient mechanism, if true, the component will "
+ + " look for a client instance in the registry automatically
otherwise it will skip that checking")
+ private boolean autoDiscoverClient = true;
public KinesisClient getAmazonKinesisClient() {
return amazonKinesisClient;
@@ -173,6 +176,14 @@ public class Kinesis2Configuration implements Cloneable {
public void setTrustAllCertificates(boolean trustAllCertificates) {
this.trustAllCertificates = trustAllCertificates;
}
+
+ public boolean isAutoDiscoverClient() {
+ return autoDiscoverClient;
+ }
+
+ public void setAutoDiscoverClient(boolean autoDiscoverClient) {
+ this.autoDiscoverClient = autoDiscoverClient;
+ }
// *************************************************
//
diff --git
a/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentConfigurationTest.java
b/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentConfigurationTest.java
index 279800c..12c4ba8 100644
---
a/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentConfigurationTest.java
+++
b/components/camel-aws2-kinesis/src/test/java/org/apache/camel/component/aws2/kinesis/KinesisComponentConfigurationTest.java
@@ -77,4 +77,15 @@ public class KinesisComponentConfigurationTest extends
CamelTestSupport {
assertEquals("localhost", endpoint.getConfiguration().getProxyHost());
assertEquals(Integer.valueOf(9000),
endpoint.getConfiguration().getProxyPort());
}
+
+ @Test
+ public void createEndpointWithAutoDiscoverClientFalse() throws Exception {
+ Kinesis2Component component = context.getComponent("aws2-kinesis",
Kinesis2Component.class);
+ Kinesis2Endpoint endpoint =
(Kinesis2Endpoint)component.createEndpoint("aws2-kinesis://some_stream_name?accessKey=xxxxx&secretKey=yyyyy&autoDiscoverClient=false");
+
+ assertEquals("some_stream_name",
endpoint.getConfiguration().getStreamName());
+ assertEquals("xxxxx", endpoint.getConfiguration().getAccessKey());
+ assertEquals("yyyyy", endpoint.getConfiguration().getSecretKey());
+ assertEquals(false,
endpoint.getConfiguration().isAutoDiscoverClient());
+ }
}
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java
index 3844653..412ad02 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/Aws2KinesisComponentBuilderFactory.java
@@ -65,6 +65,21 @@ public interface Aws2KinesisComponentBuilderFactory {
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 Aws2KinesisComponentBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Component configuration.
*
* The option is a:
@@ -313,6 +328,7 @@ public interface Aws2KinesisComponentBuilderFactory {
Object value) {
switch (name) {
case "amazonKinesisClient":
getOrCreateConfiguration((Kinesis2Component)
component).setAmazonKinesisClient((software.amazon.awssdk.services.kinesis.KinesisClient)
value); return true;
+ case "autoDiscoverClient":
getOrCreateConfiguration((Kinesis2Component)
component).setAutoDiscoverClient((boolean) value); return true;
case "configuration": ((Kinesis2Component)
component).setConfiguration((org.apache.camel.component.aws2.kinesis.Kinesis2Configuration)
value); return true;
case "proxyHost": getOrCreateConfiguration((Kinesis2Component)
component).setProxyHost((java.lang.String) value); return true;
case "proxyPort": getOrCreateConfiguration((Kinesis2Component)
component).setProxyPort((java.lang.Integer) 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 6072d0c..8f4a69d 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
@@ -1169,7 +1169,7 @@ public class StaticEndpointBuilders {
*
* @param path streamName
*/
- public static
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.Kinesis2EndpointBuilder
aws2Kinesis(
+ static
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.Kinesis2EndpointBuilder
aws2Kinesis(
String path) {
return
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.endpointBuilder("aws2-kinesis",
path);
}
@@ -1191,7 +1191,7 @@ public class StaticEndpointBuilders {
* instead of the default name
* @param path streamName
*/
- public static
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.Kinesis2EndpointBuilder
aws2Kinesis(
+ static
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.Kinesis2EndpointBuilder
aws2Kinesis(
String componentName,
String path) {
return
org.apache.camel.builder.endpoint.dsl.Kinesis2EndpointBuilderFactory.endpointBuilder(componentName,
path);
@@ -1955,7 +1955,7 @@ public class StaticEndpointBuilders {
*
* @param path streamName
*/
- static
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.KinesisFirehoseEndpointBuilder
awsKinesisFirehose(
+ public static
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.KinesisFirehoseEndpointBuilder
awsKinesisFirehose(
String path) {
return
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.endpointBuilder("aws-kinesis-firehose",
path);
}
@@ -1976,7 +1976,7 @@ public class StaticEndpointBuilders {
* instead of the default name
* @param path streamName
*/
- static
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.KinesisFirehoseEndpointBuilder
awsKinesisFirehose(
+ public static
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.KinesisFirehoseEndpointBuilder
awsKinesisFirehose(
String componentName,
String path) {
return
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.endpointBuilder(componentName,
path);
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java
index 457fcb7..911971b 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/Kinesis2EndpointBuilderFactory.java
@@ -76,6 +76,36 @@ public interface Kinesis2EndpointBuilderFactory {
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 Kinesis2EndpointConsumerBuilder 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 Kinesis2EndpointConsumerBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* To define a proxy host when instantiating the Kinesis client.
*
* The option is a: <code>java.lang.String</code> type.
@@ -950,6 +980,36 @@ public interface Kinesis2EndpointBuilderFactory {
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 Kinesis2EndpointProducerBuilder 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 Kinesis2EndpointProducerBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* To define a proxy host when instantiating the Kinesis client.
*
* The option is a: <code>java.lang.String</code> type.
@@ -1225,6 +1285,36 @@ public interface Kinesis2EndpointBuilderFactory {
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 Kinesis2EndpointBuilder 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 Kinesis2EndpointBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* To define a proxy host when instantiating the Kinesis client.
*
* The option is a: <code>java.lang.String</code> type.
