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 ba7b24e6c4d3559f51e0d7d1503e1be713b122c5
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Jul 24 08:09:13 2020 +0200
CAMEL-15310 - AWS* - Support for more than 1 client in the registry -
Camel-AWS-Lambda
---
.../aws/lambda/LambdaComponentConfigurer.java | 5 ++++
.../aws/lambda/LambdaEndpointConfigurer.java | 5 ++++
.../camel/component/aws/lambda/aws-lambda.json | 2 ++
.../src/main/docs/aws-lambda-component.adoc | 6 +++--
.../component/aws/lambda/LambdaComponent.java | 4 ++-
.../component/aws/lambda/LambdaConfiguration.java | 15 +++++++++++
.../lambda/LambdaComponentClientRegistryTest.java | 26 +++++++++++++++++++
.../dsl/AwsLambdaComponentBuilderFactory.java | 16 ++++++++++++
.../builder/endpoint/StaticEndpointBuilders.java | 8 +++---
.../endpoint/dsl/LambdaEndpointBuilderFactory.java | 30 ++++++++++++++++++++++
10 files changed, 110 insertions(+), 7 deletions(-)
diff --git
a/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaComponentConfigurer.java
b/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaComponentConfigurer.java
index 2f778dd..c2a3ce9 100644
---
a/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaComponentConfigurer.java
+++
b/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaComponentConfigurer.java
@@ -28,6 +28,8 @@ public class LambdaComponentConfigurer extends
PropertyConfigurerSupport impleme
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey":
getOrCreateConfiguration(target).setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
getOrCreateConfiguration(target).setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "awslambdaclient":
case "awsLambdaClient":
getOrCreateConfiguration(target).setAwsLambdaClient(property(camelContext,
com.amazonaws.services.lambda.AWSLambda.class, value)); return true;
case "basicpropertybinding":
@@ -53,6 +55,7 @@ public class LambdaComponentConfigurer extends
PropertyConfigurerSupport impleme
public Map<String, Object> getAllOptions(Object target) {
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("awsLambdaClient",
com.amazonaws.services.lambda.AWSLambda.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("configuration",
org.apache.camel.component.aws.lambda.LambdaConfiguration.class);
@@ -72,6 +75,8 @@ public class LambdaComponentConfigurer extends
PropertyConfigurerSupport impleme
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey": return
getOrCreateConfiguration(target).getAccessKey();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
getOrCreateConfiguration(target).isAutoDiscoverClient();
case "awslambdaclient":
case "awsLambdaClient": return
getOrCreateConfiguration(target).getAwsLambdaClient();
case "basicpropertybinding":
diff --git
a/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaEndpointConfigurer.java
b/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaEndpointConfigurer.java
index 7bebbe4..d31408e 100644
---
a/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaEndpointConfigurer.java
+++
b/components/camel-aws-lambda/src/generated/java/org/apache/camel/component/aws/lambda/LambdaEndpointConfigurer.java
@@ -21,6 +21,8 @@ public class LambdaEndpointConfigurer extends
PropertyConfigurerSupport implemen
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey":
target.getConfiguration().setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
+ case "autodiscoverclient":
+ case "autoDiscoverClient":
target.getConfiguration().setAutoDiscoverClient(property(camelContext,
boolean.class, value)); return true;
case "awslambdaclient":
case "awsLambdaClient":
target.getConfiguration().setAwsLambdaClient(property(camelContext,
com.amazonaws.services.lambda.AWSLambda.class, value)); return true;
case "basicpropertybinding":
@@ -46,6 +48,7 @@ public class LambdaEndpointConfigurer extends
PropertyConfigurerSupport implemen
public Map<String, Object> getAllOptions(Object target) {
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("awsLambdaClient",
com.amazonaws.services.lambda.AWSLambda.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("lazyStartProducer", boolean.class);
@@ -65,6 +68,8 @@ public class LambdaEndpointConfigurer extends
PropertyConfigurerSupport implemen
switch (ignoreCase ? name.toLowerCase() : name) {
case "accesskey":
case "accessKey": return target.getConfiguration().getAccessKey();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
target.getConfiguration().isAutoDiscoverClient();
case "awslambdaclient":
case "awsLambdaClient": return
target.getConfiguration().getAwsLambdaClient();
case "basicpropertybinding":
diff --git
a/components/camel-aws-lambda/src/generated/resources/org/apache/camel/component/aws/lambda/aws-lambda.json
b/components/camel-aws-lambda/src/generated/resources/org/apache/camel/component/aws/lambda/aws-lambda.json
index 73c0e54..a44b6ba 100644
---
a/components/camel-aws-lambda/src/generated/resources/org/apache/camel/component/aws/lambda/aws-lambda.json
+++
b/components/camel-aws-lambda/src/generated/resources/org/apache/camel/component/aws/lambda/aws-lambda.json
@@ -21,6 +21,7 @@
"lenientProperties": false
},
"componentProperties": {
+ "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.lambda.LambdaConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the re [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "producer", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws.lambda.LambdaConfiguration",
"deprecated": false, "secret": false, "description": "The AWS Lambda default
configuration" },
"lazyStartProducer": { "kind": "property", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the r [...]
"operation": { "kind": "property", "displayName": "Operation", "group":
"producer", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.aws.lambda.LambdaOperations", "enum": [
"listFunctions", "getFunction", "createAlias", "deleteAlias", "getAlias",
"listAliases", "createFunction", "deleteFunction", "invokeFunction",
"updateFunction", "createEventSourceMapping", "deleteEventSourceMapping",
"listEventSourceMapping", "listTags", "tagResource", "unt [...]
@@ -35,6 +36,7 @@
},
"properties": {
"function": { "kind": "path", "displayName": "Function", "group":
"producer", "label": "", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "secret":
false, "description": "Name of the Lambda function." },
+ "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.lambda.LambdaConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in the r [...]
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Whether the producer should be started
lazy (on the first message). By starting lazy you can use this to allow
CamelContext and routes to startup in situations where a producer may otherwise
fail during starting and cause the [...]
"operation": { "kind": "parameter", "displayName": "Operation", "group":
"producer", "label": "", "required": false, "type": "object", "javaType":
"org.apache.camel.component.aws.lambda.LambdaOperations", "enum": [
"listFunctions", "getFunction", "createAlias", "deleteAlias", "getAlias",
"listAliases", "createFunction", "deleteFunction", "invokeFunction",
"updateFunction", "createEventSourceMapping", "deleteEventSourceMapping",
"listEventSourceMapping", "listTags", "tagResource", "un [...]
"region": { "kind": "parameter", "displayName": "Region", "group":
"producer", "label": "producer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "secret": false,
"configurationClass":
"org.apache.camel.component.aws.lambda.LambdaConfiguration",
"configurationField": "configuration", "description": "Amazon AWS Region. When
using this parameter, the configuration will expect the capitalized name of the
region (for example AP_EAST_1) You'll n [...]
diff --git
a/components/camel-aws-lambda/src/main/docs/aws-lambda-component.adoc
b/components/camel-aws-lambda/src/main/docs/aws-lambda-component.adoc
index bee5776..d5ca4ef 100644
--- a/components/camel-aws-lambda/src/main/docs/aws-lambda-component.adoc
+++ b/components/camel-aws-lambda/src/main/docs/aws-lambda-component.adoc
@@ -42,13 +42,14 @@ You can append query options to the URI in the following
format,
// component options: START
-The AWS Lambda component supports 11 options, which are listed below.
+The AWS Lambda component supports 12 options, which are listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *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* (producer) | The AWS Lambda default configuration | |
LambdaConfiguration
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | The operation to perform. It can be listFunctions,
getFunction, createFunction, deleteFunction or invokeFunction. The value can be
one of: listFunctions, getFunction, createAlias, deleteAlias, getAlias,
listAliases, createFunction, deleteFunction, invokeFunction, updateFunction,
createEventSourceMapping, deleteEventSourceMapping, listEventSourceMapping,
listTags, tagResource, untagResource, publishVersion, listVersions |
invokeFunction | LambdaOperations
@@ -85,12 +86,13 @@ with the following path and query parameters:
|===
-=== Query Parameters (11 parameters):
+=== Query Parameters (12 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *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
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
| *operation* (producer) | The operation to perform. It can be listFunctions,
getFunction, createFunction, deleteFunction or invokeFunction. The value can be
one of: listFunctions, getFunction, createAlias, deleteAlias, getAlias,
listAliases, createFunction, deleteFunction, invokeFunction, updateFunction,
createEventSourceMapping, deleteEventSourceMapping, listEventSourceMapping,
listTags, tagResource, untagResource, publishVersion, listVersions |
invokeFunction | LambdaOperations
| *region* (producer) | Amazon AWS Region. When using this parameter, the
configuration will expect the capitalized name of the region (for example
AP_EAST_1) You'll need to use the name Regions.EU_WEST_1.name() | | String
diff --git
a/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaComponent.java
b/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaComponent.java
index e66e140..049ee88 100644
---
a/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaComponent.java
+++
b/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaComponent.java
@@ -48,7 +48,9 @@ public class LambdaComponent extends DefaultComponent {
LambdaEndpoint endpoint = new LambdaEndpoint(uri, this, configuration);
setProperties(endpoint, parameters);
endpoint.setFunction(remaining);
- checkAndSetRegistryClient(configuration);
+ if (endpoint.getConfiguration().isAutoDiscoverClient()) {
+ checkAndSetRegistryClient(configuration);
+ }
if (configuration.getAwsLambdaClient() == null &&
(configuration.getAccessKey() == null || configuration.getSecretKey() == null))
{
throw new IllegalArgumentException("accessKey/secretKey or
awsLambdaClient must be specified");
}
diff --git
a/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaConfiguration.java
b/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaConfiguration.java
index db2ffd2..e0bce8d 100644
---
a/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaConfiguration.java
+++
b/components/camel-aws-lambda/src/main/java/org/apache/camel/component/aws/lambda/LambdaConfiguration.java
@@ -41,6 +41,8 @@ public class LambdaConfiguration implements Cloneable {
private Integer proxyPort;
@UriParam(label = "advanced")
private AWSLambda awsLambdaClient;
+ @UriParam(label = "common", defaultValue = "true")
+ private boolean autoDiscoverClient = true;
public AWSLambda getAwsLambdaClient() {
return awsLambdaClient;
@@ -131,6 +133,19 @@ public class LambdaConfiguration implements Cloneable {
this.proxyPort = proxyPort;
}
+ 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;
+ }
+
// *************************************************
//
// *************************************************
diff --git
a/components/camel-aws-lambda/src/test/java/org/apache/camel/component/aws/lambda/LambdaComponentClientRegistryTest.java
b/components/camel-aws-lambda/src/test/java/org/apache/camel/component/aws/lambda/LambdaComponentClientRegistryTest.java
index 003dde9..72cf4ee 100644
---
a/components/camel-aws-lambda/src/test/java/org/apache/camel/component/aws/lambda/LambdaComponentClientRegistryTest.java
+++
b/components/camel-aws-lambda/src/test/java/org/apache/camel/component/aws/lambda/LambdaComponentClientRegistryTest.java
@@ -22,6 +22,8 @@ import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Test;
import static org.junit.jupiter.api.Assertions.assertNotNull;
+import static org.junit.jupiter.api.Assertions.assertNotSame;
+import static org.junit.jupiter.api.Assertions.assertSame;
import static org.junit.jupiter.api.Assertions.assertThrows;
import static org.mockito.Mockito.mock;
@@ -47,4 +49,28 @@ public class LambdaComponentClientRegistryTest extends
CamelTestSupport {
() -> component.createEndpoint(
"aws-lambda://myFunction?operation=getFunction&awsLambdaClient=#awsLambdaClient&accessKey=xxx&secretKey=yyy"));
}
+
+ @Test
+ public void createEndpointWithAutoDiscoverClientFalse() throws Exception {
+
+ AWSLambdaClient awsLambdaClient = mock(AWSLambdaClient.class);
+ context.getRegistry().bind("awsLambdaClient", awsLambdaClient);
+ LambdaComponent component = context.getComponent("aws-lambda",
LambdaComponent.class);
+ LambdaEndpoint endpoint = (LambdaEndpoint) component.createEndpoint(
+
"aws-lambda://myFunction?operation=getFunction&accessKey=xxx&secretKey=yyy&autoDiscoverClient=false");
+
+ assertNotSame(awsLambdaClient,
endpoint.getConfiguration().getAwsLambdaClient());
+ }
+
+ @Test
+ public void createEndpointWithAutoDiscoverClientTrue() throws Exception {
+
+ AWSLambdaClient awsLambdaClient = mock(AWSLambdaClient.class);
+ context.getRegistry().bind("awsLambdaClient", awsLambdaClient);
+ LambdaComponent component = context.getComponent("aws-lambda",
LambdaComponent.class);
+ LambdaEndpoint endpoint = (LambdaEndpoint) component.createEndpoint(
+
"aws-lambda://myFunction?operation=getFunction&accessKey=xxx&secretKey=yyy");
+
+ assertSame(awsLambdaClient,
endpoint.getConfiguration().getAwsLambdaClient());
+ }
}
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsLambdaComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsLambdaComponentBuilderFactory.java
index 5bb2d8d..6c353c3 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsLambdaComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsLambdaComponentBuilderFactory.java
@@ -49,6 +49,21 @@ public interface AwsLambdaComponentBuilderFactory {
extends
ComponentBuilder<LambdaComponent> {
/**
+ * 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 AwsLambdaComponentBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* The AWS Lambda default configuration.
*
* The option is a:
@@ -219,6 +234,7 @@ public interface AwsLambdaComponentBuilderFactory {
String name,
Object value) {
switch (name) {
+ case "autoDiscoverClient":
getOrCreateConfiguration((LambdaComponent)
component).setAutoDiscoverClient((boolean) value); return true;
case "configuration": ((LambdaComponent)
component).setConfiguration((org.apache.camel.component.aws.lambda.LambdaConfiguration)
value); return true;
case "lazyStartProducer": ((LambdaComponent)
component).setLazyStartProducer((boolean) value); return true;
case "operation": getOrCreateConfiguration((LambdaComponent)
component).setOperation((org.apache.camel.component.aws.lambda.LambdaOperations)
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 4a11e12..4348ec9 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
@@ -2037,7 +2037,7 @@ public class StaticEndpointBuilders {
*
* @param path function
*/
- public static
org.apache.camel.builder.endpoint.dsl.LambdaEndpointBuilderFactory.LambdaEndpointBuilder
awsLambda(
+ static
org.apache.camel.builder.endpoint.dsl.LambdaEndpointBuilderFactory.LambdaEndpointBuilder
awsLambda(
String path) {
return
org.apache.camel.builder.endpoint.dsl.LambdaEndpointBuilderFactory.endpointBuilder("aws-lambda",
path);
}
@@ -2058,7 +2058,7 @@ public class StaticEndpointBuilders {
* instead of the default name
* @param path function
*/
- public static
org.apache.camel.builder.endpoint.dsl.LambdaEndpointBuilderFactory.LambdaEndpointBuilder
awsLambda(
+ static
org.apache.camel.builder.endpoint.dsl.LambdaEndpointBuilderFactory.LambdaEndpointBuilder
awsLambda(
String componentName,
String path) {
return
org.apache.camel.builder.endpoint.dsl.LambdaEndpointBuilderFactory.endpointBuilder(componentName,
path);
@@ -15516,7 +15516,7 @@ public class StaticEndpointBuilders {
*
* @param path serverUrls/path
*/
- static
org.apache.camel.builder.endpoint.dsl.ZooKeeperEndpointBuilderFactory.ZooKeeperEndpointBuilder
zookeeper(
+ public static
org.apache.camel.builder.endpoint.dsl.ZooKeeperEndpointBuilderFactory.ZooKeeperEndpointBuilder
zookeeper(
String path) {
return
org.apache.camel.builder.endpoint.dsl.ZooKeeperEndpointBuilderFactory.endpointBuilder("zookeeper",
path);
}
@@ -15540,7 +15540,7 @@ public class StaticEndpointBuilders {
* instead of the default name
* @param path serverUrls/path
*/
- static
org.apache.camel.builder.endpoint.dsl.ZooKeeperEndpointBuilderFactory.ZooKeeperEndpointBuilder
zookeeper(
+ public static
org.apache.camel.builder.endpoint.dsl.ZooKeeperEndpointBuilderFactory.ZooKeeperEndpointBuilder
zookeeper(
String componentName,
String path) {
return
org.apache.camel.builder.endpoint.dsl.ZooKeeperEndpointBuilderFactory.endpointBuilder(componentName,
path);
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java
index 8eecfa1..48eb887 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/LambdaEndpointBuilderFactory.java
@@ -38,6 +38,36 @@ public interface LambdaEndpointBuilderFactory {
return (AdvancedLambdaEndpointBuilder) 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 LambdaEndpointBuilder 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 LambdaEndpointBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes
to
* startup in situations where a producer may otherwise fail during
