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 b7bd21a844332ca0a890c8eac8cab7028d1e1392
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Thu Jul 23 08:36:11 2020 +0200
CAMEL-15310 - AWS* - Support for more than 1 client in the registry -
Camel-AWS-Kinesis
---
.../aws/kinesis/KinesisComponentConfigurer.java | 5 ++
.../aws/kinesis/KinesisEndpointConfigurer.java | 5 ++
.../camel/component/aws/kinesis/aws-kinesis.json | 2 +
.../src/main/docs/aws-kinesis-component.adoc | 6 +-
.../component/aws/kinesis/KinesisComponent.java | 4 +-
.../aws/kinesis/KinesisConfiguration.java | 13 +++-
.../kinesis/KinesisComponentConfigurationTest.java | 11 +++
.../dsl/AwsKinesisComponentBuilderFactory.java | 16 ++++
.../builder/endpoint/StaticEndpointBuilders.java | 8 +-
.../dsl/KinesisEndpointBuilderFactory.java | 90 ++++++++++++++++++++++
10 files changed, 152 insertions(+), 8 deletions(-)
diff --git
a/components/camel-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurer.java
b/components/camel-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurer.java
index 645c008..91201d3 100644
---
a/components/camel-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurer.java
+++
b/components/camel-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurer.java
@@ -30,6 +30,8 @@ public class KinesisComponentConfigurer extends
PropertyConfigurerSupport implem
case "accessKey":
getOrCreateConfiguration(target).setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
case "amazonkinesisclient":
case "amazonKinesisClient":
getOrCreateConfiguration(target).setAmazonKinesisClient(property(camelContext,
com.amazonaws.services.kinesis.AmazonKinesis.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":
@@ -65,6 +67,7 @@ public class KinesisComponentConfigurer extends
PropertyConfigurerSupport implem
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
answer.put("amazonKinesisClient",
com.amazonaws.services.kinesis.AmazonKinesis.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("bridgeErrorHandler", boolean.class);
answer.put("configuration",
org.apache.camel.component.aws.kinesis.KinesisConfiguration.class);
@@ -90,6 +93,8 @@ public class KinesisComponentConfigurer extends
PropertyConfigurerSupport implem
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-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisEndpointConfigurer.java
b/components/camel-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisEndpointConfigurer.java
index 5a52d34..83b1cde 100644
---
a/components/camel-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisEndpointConfigurer.java
+++
b/components/camel-aws-kinesis/src/generated/java/org/apache/camel/component/aws/kinesis/KinesisEndpointConfigurer.java
@@ -23,6 +23,8 @@ public class KinesisEndpointConfigurer extends
PropertyConfigurerSupport impleme
case "accessKey":
target.getConfiguration().setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
case "amazonkinesisclient":
case "amazonKinesisClient":
target.getConfiguration().setAmazonKinesisClient(property(camelContext,
com.amazonaws.services.kinesis.AmazonKinesis.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":
@@ -91,6 +93,7 @@ public class KinesisEndpointConfigurer extends
PropertyConfigurerSupport impleme
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
answer.put("amazonKinesisClient",
com.amazonaws.services.kinesis.AmazonKinesis.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("backoffErrorThreshold", int.class);
answer.put("backoffIdleThreshold", int.class);
answer.put("backoffMultiplier", int.class);
@@ -134,6 +137,8 @@ public class KinesisEndpointConfigurer extends
PropertyConfigurerSupport impleme
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-aws-kinesis/src/generated/resources/org/apache/camel/component/aws/kinesis/aws-kinesis.json
b/components/camel-aws-kinesis/src/generated/resources/org/apache/camel/component/aws/kinesis/aws-kinesis.json
index 3590503..ad40fa9 100644
---
a/components/camel-aws-kinesis/src/generated/resources/org/apache/camel/component/aws/kinesis/aws-kinesis.json
+++
b/components/camel-aws-kinesis/src/generated/resources/org/apache/camel/component/aws/kinesis/aws-kinesis.json
@@ -22,6 +22,7 @@
},
"componentProperties": {
"amazonKinesisClient": { "kind": "property", "displayName": "Amazon
Kinesis Client", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "com.amazonaws.services.kinesis.AmazonKinesis",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws.kinesis.KinesisConfiguration",
"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.aws.kinesis.KinesisConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "common", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws.kinesis.KinesisConfiguration",
"deprecated": false, "secret": false, "description": "The 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.aws.kinesis.KinesisConfiguration",
"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.aws.kinesis.KinesisConfiguration",
"configurationField": "configuration", "description": "To define a proxy port
when instantiating the Kinesis client" },
@@ -41,6 +42,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.aws.kinesis.KinesisConfiguration",
"configurationField": "configuration", "description": "Name of the stream" },
"amazonKinesisClient": { "kind": "parameter", "displayName": "Amazon
Kinesis Client", "group": "common", "label": "", "required": false, "type":
"object", "javaType": "com.amazonaws.services.kinesis.AmazonKinesis",
"deprecated": false, "secret": false, "configurationClass":
"org.apache.camel.component.aws.kinesis.KinesisConfiguration",
"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.aws.kinesis.KinesisConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the [...]
"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.aws.kinesis.KinesisConfiguration",
"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.aws.kinesis.KinesisConfiguration",
"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": "com.amazonaws.Protocol", "enum": [ "HTTP", "HTTPS" ],
"deprecated": false, "secret": false, "defaultValue": "HTTPS",
"configurationClass":
"org.apache.camel.component.aws.kinesis.KinesisConfiguration",
"configurationField": "configuration", "description": "To define a proxy
protocol when instantiating the Kinesis client" },
diff --git
a/components/camel-aws-kinesis/src/main/docs/aws-kinesis-component.adoc
b/components/camel-aws-kinesis/src/main/docs/aws-kinesis-component.adoc
index f45237e..57d0d81 100644
--- a/components/camel-aws-kinesis/src/main/docs/aws-kinesis-component.adoc
+++ b/components/camel-aws-kinesis/src/main/docs/aws-kinesis-component.adoc
@@ -37,7 +37,7 @@ The stream needs to be created prior to it being used. +
// component options: START
-The AWS Kinesis component supports 16 options, which are listed below.
+The AWS Kinesis component supports 17 options, which are listed below.
@@ -45,6 +45,7 @@ The AWS Kinesis component supports 16 options, which are
listed below.
|===
| Name | Description | Default | Type
| *amazonKinesisClient* (common) | Amazon Kinesis client to use for all
requests for this endpoint | | AmazonKinesis
+| *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 | |
KinesisConfiguration
| *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
@@ -88,13 +89,14 @@ with the following path and query parameters:
|===
-=== Query Parameters (34 parameters):
+=== Query Parameters (35 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 | | AmazonKinesis
+| *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-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java
b/components/camel-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java
index 46309ce..2ac6162 100644
---
a/components/camel-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java
+++
b/components/camel-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisComponent.java
@@ -48,7 +48,9 @@ public class KinesisComponent extends DefaultComponent {
configuration.setStreamName(remaining);
KinesisEndpoint endpoint = new KinesisEndpoint(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-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisConfiguration.java
b/components/camel-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisConfiguration.java
index 25afb05..9e65776 100644
---
a/components/camel-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisConfiguration.java
+++
b/components/camel-aws-kinesis/src/main/java/org/apache/camel/component/aws/kinesis/KinesisConfiguration.java
@@ -59,6 +59,9 @@ public class KinesisConfiguration implements Cloneable {
private String proxyHost;
@UriParam(description = "To define a proxy port when instantiating the
Kinesis client")
private Integer proxyPort;
+ @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 AmazonKinesis getAmazonKinesisClient() {
return amazonKinesisClient;
@@ -162,7 +165,15 @@ public class KinesisConfiguration implements Cloneable {
public void setProxyPort(Integer proxyPort) {
this.proxyPort = proxyPort;
- }
+ }
+
+ public boolean isAutoDiscoverClient() {
+ return autoDiscoverClient;
+ }
+
+ public void setAutoDiscoverClient(boolean autoDiscoverClient) {
+ this.autoDiscoverClient = autoDiscoverClient;
+ }
// *************************************************
//
diff --git
a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurationTest.java
b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurationTest.java
index 720b2d8..0ed6860 100644
---
a/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurationTest.java
+++
b/components/camel-aws-kinesis/src/test/java/org/apache/camel/component/aws/kinesis/KinesisComponentConfigurationTest.java
@@ -76,4 +76,15 @@ public class KinesisComponentConfigurationTest extends
CamelTestSupport {
assertEquals("localhost", endpoint.getConfiguration().getProxyHost());
assertEquals(Integer.valueOf(9000),
endpoint.getConfiguration().getProxyPort());
}
+
+ @Test
+ public void createEndpointWithAutoDiscoverClientFalse() throws Exception {
+ KinesisComponent component = context.getComponent("aws-kinesis",
KinesisComponent.class);
+ KinesisEndpoint endpoint =
(KinesisEndpoint)component.createEndpoint("aws-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/AwsKinesisComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsKinesisComponentBuilderFactory.java
index 38a75ec..bea029a 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsKinesisComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsKinesisComponentBuilderFactory.java
@@ -62,6 +62,21 @@ public interface AwsKinesisComponentBuilderFactory {
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 AwsKinesisComponentBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* The component configuration.
*
* The option is a:
@@ -295,6 +310,7 @@ public interface AwsKinesisComponentBuilderFactory {
Object value) {
switch (name) {
case "amazonKinesisClient":
getOrCreateConfiguration((KinesisComponent)
component).setAmazonKinesisClient((com.amazonaws.services.kinesis.AmazonKinesis)
value); return true;
+ case "autoDiscoverClient":
getOrCreateConfiguration((KinesisComponent)
component).setAutoDiscoverClient((boolean) value); return true;
case "configuration": ((KinesisComponent)
component).setConfiguration((org.apache.camel.component.aws.kinesis.KinesisConfiguration)
value); return true;
case "proxyHost": getOrCreateConfiguration((KinesisComponent)
component).setProxyHost((java.lang.String) value); return true;
case "proxyPort": getOrCreateConfiguration((KinesisComponent)
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 ee5771b..6072d0c 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
*/
- static
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3EndpointBuilder
aws2S3(
+ public 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
*/
- static
org.apache.camel.builder.endpoint.dsl.AWS2S3EndpointBuilderFactory.AWS2S3EndpointBuilder
aws2S3(
+ public 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);
@@ -1955,7 +1955,7 @@ public class StaticEndpointBuilders {
*
* @param path streamName
*/
- public static
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.KinesisFirehoseEndpointBuilder
awsKinesisFirehose(
+ 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
*/
- public static
org.apache.camel.builder.endpoint.dsl.KinesisFirehoseEndpointBuilderFactory.KinesisFirehoseEndpointBuilder
awsKinesisFirehose(
+ 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/KinesisEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
index 1b021a79..85e3a20 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
@@ -73,6 +73,36 @@ public interface KinesisEndpointBuilderFactory {
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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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.
@@ -918,6 +948,36 @@ public interface KinesisEndpointBuilderFactory {
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 KinesisEndpointProducerBuilder 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 KinesisEndpointProducerBuilder 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.
@@ -1162,6 +1222,36 @@ public interface KinesisEndpointBuilderFactory {
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 KinesisEndpointBuilder 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 KinesisEndpointBuilder 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.
