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 de1a79ef76266ee12c6efd5c852136c468fedc28
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Tue Jul 21 08:34:47 2020 +0200
Camel-AWS-DDB: Fixed CS
---
.../ddbstream/DdbStreamComponentConfigurer.java | 5 ++++
.../aws/ddbstream/DdbStreamEndpointConfigurer.java | 5 ++++
.../component/aws/ddbstream/aws-ddbstream.json | 2 ++
.../src/main/docs/aws-ddbstream-component.adoc | 6 +++--
.../aws/ddbstream/DdbStreamConfiguration.java | 2 +-
.../dsl/AwsDdbstreamComponentBuilderFactory.java | 16 ++++++++++++
.../dsl/DdbStreamEndpointBuilderFactory.java | 30 ++++++++++++++++++++++
7 files changed, 63 insertions(+), 3 deletions(-)
diff --git
a/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponentConfigurer.java
b/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponentConfigurer.java
index f31eb2a..4b31c9a 100644
---
a/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponentConfigurer.java
+++
b/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamComponentConfigurer.java
@@ -30,6 +30,8 @@ public class DdbStreamComponentConfigurer extends
PropertyConfigurerSupport impl
case "accessKey":
getOrCreateConfiguration(target).setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
case "amazondynamodbstreamsclient":
case "amazonDynamoDbStreamsClient":
getOrCreateConfiguration(target).setAmazonDynamoDbStreamsClient(property(camelContext,
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams.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":
@@ -59,6 +61,7 @@ public class DdbStreamComponentConfigurer extends
PropertyConfigurerSupport impl
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
answer.put("amazonDynamoDbStreamsClient",
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("basicPropertyBinding", boolean.class);
answer.put("bridgeErrorHandler", boolean.class);
answer.put("configuration",
org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration.class);
@@ -81,6 +84,8 @@ public class DdbStreamComponentConfigurer extends
PropertyConfigurerSupport impl
case "accessKey": return
getOrCreateConfiguration(target).getAccessKey();
case "amazondynamodbstreamsclient":
case "amazonDynamoDbStreamsClient": return
getOrCreateConfiguration(target).getAmazonDynamoDbStreamsClient();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
getOrCreateConfiguration(target).isAutoDiscoverClient();
case "basicpropertybinding":
case "basicPropertyBinding": return target.isBasicPropertyBinding();
case "bridgeerrorhandler":
diff --git
a/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpointConfigurer.java
b/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpointConfigurer.java
index f304928..f5762a3 100644
---
a/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpointConfigurer.java
+++
b/components/camel-aws-ddb/src/generated/java/org/apache/camel/component/aws/ddbstream/DdbStreamEndpointConfigurer.java
@@ -23,6 +23,8 @@ public class DdbStreamEndpointConfigurer extends
PropertyConfigurerSupport imple
case "accessKey":
target.getConfiguration().setAccessKey(property(camelContext,
java.lang.String.class, value)); return true;
case "amazondynamodbstreamsclient":
case "amazonDynamoDbStreamsClient":
target.getConfiguration().setAmazonDynamoDbStreamsClient(property(camelContext,
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams.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":
@@ -85,6 +87,7 @@ public class DdbStreamEndpointConfigurer extends
PropertyConfigurerSupport imple
Map<String, Object> answer = new CaseInsensitiveMap();
answer.put("accessKey", java.lang.String.class);
answer.put("amazonDynamoDbStreamsClient",
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams.class);
+ answer.put("autoDiscoverClient", boolean.class);
answer.put("backoffErrorThreshold", int.class);
answer.put("backoffIdleThreshold", int.class);
answer.put("backoffMultiplier", int.class);
@@ -125,6 +128,8 @@ public class DdbStreamEndpointConfigurer extends
PropertyConfigurerSupport imple
case "accessKey": return target.getConfiguration().getAccessKey();
case "amazondynamodbstreamsclient":
case "amazonDynamoDbStreamsClient": return
target.getConfiguration().getAmazonDynamoDbStreamsClient();
+ case "autodiscoverclient":
+ case "autoDiscoverClient": return
target.getConfiguration().isAutoDiscoverClient();
case "backofferrorthreshold":
case "backoffErrorThreshold": return target.getBackoffErrorThreshold();
case "backoffidlethreshold":
diff --git
a/components/camel-aws-ddb/src/generated/resources/org/apache/camel/component/aws/ddbstream/aws-ddbstream.json
b/components/camel-aws-ddb/src/generated/resources/org/apache/camel/component/aws/ddbstream/aws-ddbstream.json
index e824fbc..6e58c60 100644
---
a/components/camel-aws-ddb/src/generated/resources/org/apache/camel/component/aws/ddbstream/aws-ddbstream.json
+++
b/components/camel-aws-ddb/src/generated/resources/org/apache/camel/component/aws/ddbstream/aws-ddbstream.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.ddbstream.DdbStreamConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in [...]
"amazonDynamoDbStreamsClient": { "kind": "property", "displayName":
"Amazon Dynamo Db Streams Client", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration",
"configurationField": "configuration", "description": "Amazon DynamoDB client
to use for all requests for th [...]
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by [...]
"configuration": { "kind": "property", "displayName": "Configuration",
"group": "consumer", "label": "", "required": false, "type": "object",
"javaType": "org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration",
"deprecated": false, "secret": false, "description": "The component
configuration" },
@@ -37,6 +38,7 @@
},
"properties": {
"tableName": { "kind": "path", "displayName": "Table Name", "group":
"consumer", "label": "consumer", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"secret": false, "configurationClass":
"org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration",
"configurationField": "configuration", "description": "Name of the dynamodb
table" },
+ "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.ddbstream.DdbStreamConfiguration",
"configurationField": "configuration", "description": "Setting the
autoDiscoverClient mechanism, if true, the component will look for a client
instance in [...]
"amazonDynamoDbStreamsClient": { "kind": "parameter", "displayName":
"Amazon Dynamo Db Streams Client", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams", "deprecated": false,
"secret": false, "configurationClass":
"org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration",
"configurationField": "configuration", "description": "Amazon DynamoDB client
to use for all requests for t [...]
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "secret": false,
"defaultValue": false, "description": "Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled b [...]
"iteratorType": { "kind": "parameter", "displayName": "Iterator Type",
"group": "consumer", "label": "consumer", "required": false, "type": "object",
"javaType": "com.amazonaws.services.dynamodbv2.model.ShardIteratorType",
"enum": [ "TRIM_HORIZON", "LATEST", "AT_SEQUENCE_NUMBER",
"AFTER_SEQUENCE_NUMBER" ], "deprecated": false, "secret": false,
"defaultValue": "LATEST", "configurationClass":
"org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration",
"configurationField": "conf [...]
diff --git
a/components/camel-aws-ddb/src/main/docs/aws-ddbstream-component.adoc
b/components/camel-aws-ddb/src/main/docs/aws-ddbstream-component.adoc
index 962ea43..9b63f6e 100644
--- a/components/camel-aws-ddb/src/main/docs/aws-ddbstream-component.adoc
+++ b/components/camel-aws-ddb/src/main/docs/aws-ddbstream-component.adoc
@@ -37,13 +37,14 @@ The stream needs to be created prior to it being used. +
// component options: START
-The AWS DynamoDB Streams component supports 13 options, which are listed below.
+The AWS DynamoDB Streams component supports 14 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
| *amazonDynamoDbStreamsClient* (consumer) | Amazon DynamoDB client to use for
all requests for this endpoint | | AmazonDynamoDBStreams
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *configuration* (consumer) | The component configuration | |
DdbStreamConfiguration
@@ -84,12 +85,13 @@ with the following path and query parameters:
|===
-=== Query Parameters (31 parameters):
+=== Query Parameters (32 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
| *amazonDynamoDbStreamsClient* (consumer) | Amazon DynamoDB client to use for
all requests for this endpoint | | AmazonDynamoDBStreams
| *bridgeErrorHandler* (consumer) | Allows for bridging the consumer to the
Camel routing Error Handler, which mean any exceptions occurred while the
consumer is trying to pickup incoming messages, or the likes, will now be
processed as a message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
| *iteratorType* (consumer) | Defines where in the DynaboDB stream to start
getting records. Note that using TRIM_HORIZON can cause a significant delay
before the stream has caught up to real-time. if {AT,AFTER}_SEQUENCE_NUMBER are
used, then a sequenceNumberProvider MUST be supplied. The value can be one of:
TRIM_HORIZON, LATEST, AT_SEQUENCE_NUMBER, AFTER_SEQUENCE_NUMBER | LATEST |
ShardIteratorType
diff --git
a/components/camel-aws-ddb/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConfiguration.java
b/components/camel-aws-ddb/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConfiguration.java
index b93f1ba..b09d2ef 100644
---
a/components/camel-aws-ddb/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConfiguration.java
+++
b/components/camel-aws-ddb/src/main/java/org/apache/camel/component/aws/ddbstream/DdbStreamConfiguration.java
@@ -64,7 +64,7 @@ public class DdbStreamConfiguration implements Cloneable {
@UriParam(description = "To define a proxy port when instantiating the
DDBStreams 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")
+ + " look for a client instance in the registry automatically
otherwise it will skip that checking")
private boolean autoDiscoverClient = true;
public AmazonDynamoDBStreams getAmazonDynamoDbStreamsClient() {
diff --git
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbstreamComponentBuilderFactory.java
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbstreamComponentBuilderFactory.java
index 7411716..30cd912 100644
---
a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbstreamComponentBuilderFactory.java
+++
b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbstreamComponentBuilderFactory.java
@@ -49,6 +49,21 @@ public interface AwsDdbstreamComponentBuilderFactory {
extends
ComponentBuilder<DdbStreamComponent> {
/**
+ * 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 AwsDdbstreamComponentBuilder autoDiscoverClient(
+ boolean autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Amazon DynamoDB client to use for all requests for this endpoint.
*
* The option is a:
@@ -248,6 +263,7 @@ public interface AwsDdbstreamComponentBuilderFactory {
String name,
Object value) {
switch (name) {
+ case "autoDiscoverClient":
getOrCreateConfiguration((DdbStreamComponent)
component).setAutoDiscoverClient((boolean) value); return true;
case "amazonDynamoDbStreamsClient":
getOrCreateConfiguration((DdbStreamComponent)
component).setAmazonDynamoDbStreamsClient((com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams)
value); return true;
case "bridgeErrorHandler": ((DdbStreamComponent)
component).setBridgeErrorHandler((boolean) value); return true;
case "configuration": ((DdbStreamComponent)
component).setConfiguration((org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration)
value); return true;
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java
index 0298b0d..0671c40 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java
@@ -45,6 +45,36 @@ public interface DdbStreamEndpointBuilderFactory {
return (AdvancedDdbStreamEndpointBuilder) 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 DdbStreamEndpointBuilder 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 DdbStreamEndpointBuilder autoDiscoverClient(
+ String autoDiscoverClient) {
+ doSetProperty("autoDiscoverClient", autoDiscoverClient);
+ return this;
+ }
+ /**
* Amazon DynamoDB client to use for all requests for this endpoint.
*
* The option is a:
