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 76b90cd608ffc32fe7deaed2b7089aa4b2384fc8 Author: Andrea Cosentino <[email protected]> AuthorDate: Wed Feb 24 13:28:22 2021 +0100 CAMEL-16115 - Remove Camel-AWS-* components - AWS-DDB --- .../component/ComponentsBuilderFactory.java | 30 +- .../dsl/AwsDdbComponentBuilderFactory.java | 375 ------- .../dsl/AwsDdbstreamComponentBuilderFactory.java | 333 ------ .../builder/endpoint/StaticEndpointBuilders.java | 92 +- .../endpoint/dsl/DdbEndpointBuilderFactory.java | 507 --------- .../dsl/DdbStreamEndpointBuilderFactory.java | 1087 -------------------- 6 files changed, 2 insertions(+), 2422 deletions(-) diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java index b2ed890..6636ec21 100644 --- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java +++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/ComponentsBuilderFactory.java @@ -320,34 +320,6 @@ public interface ComponentsBuilderFactory { return org.apache.camel.builder.component.dsl.AwsCwComponentBuilderFactory.awsCw(); } /** - * AWS DynamoDB (camel-aws-ddb) - * Store and retrieve data from AWS DynamoDB service. - * - * Category: cloud,database,nosql - * Since: 2.10 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * @return the dsl builder - */ - @Deprecated - static org.apache.camel.builder.component.dsl.AwsDdbComponentBuilderFactory.AwsDdbComponentBuilder awsDdb() { - return org.apache.camel.builder.component.dsl.AwsDdbComponentBuilderFactory.awsDdb(); - } - /** - * AWS DynamoDB Streams (camel-aws-ddb) - * Receive messages from AWS DynamoDB Stream service. - * - * Category: cloud,messaging,streams - * Since: 2.17 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * @return the dsl builder - */ - @Deprecated - static org.apache.camel.builder.component.dsl.AwsDdbstreamComponentBuilderFactory.AwsDdbstreamComponentBuilder awsDdbstream() { - return org.apache.camel.builder.component.dsl.AwsDdbstreamComponentBuilderFactory.awsDdbstream(); - } - /** * AWS S3 Storage Service (camel-aws-s3) * Store and retrieve objects from AWS S3 Storage Service. * @@ -4736,4 +4708,4 @@ public interface ComponentsBuilderFactory { static org.apache.camel.builder.component.dsl.ZookeeperMasterComponentBuilderFactory.ZookeeperMasterComponentBuilder zookeeperMaster() { return org.apache.camel.builder.component.dsl.ZookeeperMasterComponentBuilderFactory.zookeeperMaster(); } -} \ No newline at end of file +} diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbComponentBuilderFactory.java deleted file mode 100644 index ed6abf8..0000000 --- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbComponentBuilderFactory.java +++ /dev/null @@ -1,375 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.builder.component.dsl; - -import javax.annotation.Generated; -import org.apache.camel.Component; -import org.apache.camel.builder.component.AbstractComponentBuilder; -import org.apache.camel.builder.component.ComponentBuilder; -import org.apache.camel.component.aws.ddb.DdbComponent; - -/** - * Store and retrieve data from AWS DynamoDB service. - * - * Generated by camel-package-maven-plugin - do not edit this file! - */ -@Generated("org.apache.camel.maven.packaging.ComponentDslMojo") -public interface AwsDdbComponentBuilderFactory { - - /** - * AWS DynamoDB (camel-aws-ddb) - * Store and retrieve data from AWS DynamoDB service. - * - * Category: cloud,database,nosql - * Since: 2.10 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * @return the dsl builder - */ - @Deprecated - static AwsDdbComponentBuilder awsDdb() { - return new AwsDdbComponentBuilderImpl(); - } - - /** - * Builder for the AWS DynamoDB component. - */ - interface AwsDdbComponentBuilder extends ComponentBuilder<DdbComponent> { - /** - * To use the AmazonDynamoDB as the client. - * - * The option is a: - * <code>com.amazonaws.services.dynamodbv2.AmazonDynamoDB</code> type. - * - * Group: producer - * - * @param amazonDDBClient the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder amazonDDBClient( - com.amazonaws.services.dynamodbv2.AmazonDynamoDB amazonDDBClient) { - doSetProperty("amazonDDBClient", amazonDDBClient); - 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 - * - * @param autoDiscoverClient the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder autoDiscoverClient( - boolean autoDiscoverClient) { - doSetProperty("autoDiscoverClient", autoDiscoverClient); - return this; - } - /** - * The component configuration. - * - * The option is a: - * <code>org.apache.camel.component.aws.ddb.DdbConfiguration</code> type. - * - * Group: producer - * - * @param configuration the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder configuration( - org.apache.camel.component.aws.ddb.DdbConfiguration configuration) { - doSetProperty("configuration", configuration); - return this; - } - /** - * Determines whether or not strong consistency should be enforced when - * data is read. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: producer - * - * @param consistentRead the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder consistentRead(boolean consistentRead) { - doSetProperty("consistentRead", consistentRead); - return this; - } - /** - * Attribute name when creating table. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param keyAttributeName the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder keyAttributeName( - java.lang.String keyAttributeName) { - doSetProperty("keyAttributeName", keyAttributeName); - return this; - } - /** - * Attribute type when creating table. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param keyAttributeType the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder keyAttributeType( - java.lang.String keyAttributeType) { - doSetProperty("keyAttributeType", keyAttributeType); - 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 - * 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 starting the - * producer may take a little time and prolong the total processing time - * of the processing. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: producer - * - * @param lazyStartProducer the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder lazyStartProducer( - boolean lazyStartProducer) { - doSetProperty("lazyStartProducer", lazyStartProducer); - return this; - } - /** - * What operation to perform. - * - * The option is a: - * <code>org.apache.camel.component.aws.ddb.DdbOperations</code> type. - * - * Default: PutItem - * Group: producer - * - * @param operation the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder operation( - org.apache.camel.component.aws.ddb.DdbOperations operation) { - doSetProperty("operation", operation); - return this; - } - /** - * To define a proxy host when instantiating the DDB client. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param proxyHost the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder proxyHost(java.lang.String proxyHost) { - doSetProperty("proxyHost", proxyHost); - return this; - } - /** - * To define a proxy port when instantiating the DDB client. 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(). - * - * The option is a: <code>java.lang.Integer</code> type. - * - * Group: producer - * - * @param proxyPort the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder proxyPort(java.lang.Integer proxyPort) { - doSetProperty("proxyPort", proxyPort); - return this; - } - /** - * To define a proxy protocol when instantiating the DDB client. - * - * The option is a: <code>com.amazonaws.Protocol</code> - * type. - * - * Default: HTTPS - * Group: producer - * - * @param proxyProtocol the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder proxyProtocol( - com.amazonaws.Protocol proxyProtocol) { - doSetProperty("proxyProtocol", proxyProtocol); - return this; - } - /** - * The provisioned throughput to reserve for reading resources from your - * table. - * - * The option is a: <code>java.lang.Long</code> type. - * - * Group: producer - * - * @param readCapacity the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder readCapacity(java.lang.Long readCapacity) { - doSetProperty("readCapacity", readCapacity); - return this; - } - /** - * The region in which DDB client needs to work. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param region the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder region(java.lang.String region) { - doSetProperty("region", region); - return this; - } - /** - * The provisioned throughput to reserved for writing resources to your - * table. - * - * The option is a: <code>java.lang.Long</code> type. - * - * Group: producer - * - * @param writeCapacity the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder writeCapacity( - java.lang.Long writeCapacity) { - doSetProperty("writeCapacity", writeCapacity); - return this; - } - /** - * Whether autowiring is enabled. This is used for automatic autowiring - * options (the option must be marked as autowired) by looking up in the - * registry to find if there is a single instance of matching type, - * which then gets configured on the component. This can be used for - * automatic configuring JDBC data sources, JMS connection factories, - * AWS Clients, etc. - * - * The option is a: <code>boolean</code> type. - * - * Default: true - * Group: advanced - * - * @param autowiredEnabled the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder autowiredEnabled(boolean autowiredEnabled) { - doSetProperty("autowiredEnabled", autowiredEnabled); - return this; - } - /** - * Amazon AWS Access Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param accessKey the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder accessKey(java.lang.String accessKey) { - doSetProperty("accessKey", accessKey); - return this; - } - /** - * Amazon AWS Secret Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param secretKey the value to set - * @return the dsl builder - */ - default AwsDdbComponentBuilder secretKey(java.lang.String secretKey) { - doSetProperty("secretKey", secretKey); - return this; - } - } - - class AwsDdbComponentBuilderImpl - extends - AbstractComponentBuilder<DdbComponent> - implements - AwsDdbComponentBuilder { - @Override - protected DdbComponent buildConcreteComponent() { - return new DdbComponent(); - } - private org.apache.camel.component.aws.ddb.DdbConfiguration getOrCreateConfiguration( - org.apache.camel.component.aws.ddb.DdbComponent component) { - if (component.getConfiguration() == null) { - component.setConfiguration(new org.apache.camel.component.aws.ddb.DdbConfiguration()); - } - return component.getConfiguration(); - } - @Override - protected boolean setPropertyOnComponent( - Component component, - String name, - Object value) { - switch (name) { - case "amazonDDBClient": getOrCreateConfiguration((DdbComponent) component).setAmazonDDBClient((com.amazonaws.services.dynamodbv2.AmazonDynamoDB) value); return true; - case "autoDiscoverClient": getOrCreateConfiguration((DdbComponent) component).setAutoDiscoverClient((boolean) value); return true; - case "configuration": ((DdbComponent) component).setConfiguration((org.apache.camel.component.aws.ddb.DdbConfiguration) value); return true; - case "consistentRead": getOrCreateConfiguration((DdbComponent) component).setConsistentRead((boolean) value); return true; - case "keyAttributeName": getOrCreateConfiguration((DdbComponent) component).setKeyAttributeName((java.lang.String) value); return true; - case "keyAttributeType": getOrCreateConfiguration((DdbComponent) component).setKeyAttributeType((java.lang.String) value); return true; - case "lazyStartProducer": ((DdbComponent) component).setLazyStartProducer((boolean) value); return true; - case "operation": getOrCreateConfiguration((DdbComponent) component).setOperation((org.apache.camel.component.aws.ddb.DdbOperations) value); return true; - case "proxyHost": getOrCreateConfiguration((DdbComponent) component).setProxyHost((java.lang.String) value); return true; - case "proxyPort": getOrCreateConfiguration((DdbComponent) component).setProxyPort((java.lang.Integer) value); return true; - case "proxyProtocol": getOrCreateConfiguration((DdbComponent) component).setProxyProtocol((com.amazonaws.Protocol) value); return true; - case "readCapacity": getOrCreateConfiguration((DdbComponent) component).setReadCapacity((java.lang.Long) value); return true; - case "region": getOrCreateConfiguration((DdbComponent) component).setRegion((java.lang.String) value); return true; - case "writeCapacity": getOrCreateConfiguration((DdbComponent) component).setWriteCapacity((java.lang.Long) value); return true; - case "autowiredEnabled": ((DdbComponent) component).setAutowiredEnabled((boolean) value); return true; - case "accessKey": getOrCreateConfiguration((DdbComponent) component).setAccessKey((java.lang.String) value); return true; - case "secretKey": getOrCreateConfiguration((DdbComponent) component).setSecretKey((java.lang.String) value); return true; - default: return false; - } - } - } -} \ No newline at end of file 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 deleted file mode 100644 index 7ab3911..0000000 --- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsDdbstreamComponentBuilderFactory.java +++ /dev/null @@ -1,333 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.builder.component.dsl; - -import javax.annotation.Generated; -import org.apache.camel.Component; -import org.apache.camel.builder.component.AbstractComponentBuilder; -import org.apache.camel.builder.component.ComponentBuilder; -import org.apache.camel.component.aws.ddbstream.DdbStreamComponent; - -/** - * Receive messages from AWS DynamoDB Stream service. - * - * Generated by camel-package-maven-plugin - do not edit this file! - */ -@Generated("org.apache.camel.maven.packaging.ComponentDslMojo") -public interface AwsDdbstreamComponentBuilderFactory { - - /** - * AWS DynamoDB Streams (camel-aws-ddb) - * Receive messages from AWS DynamoDB Stream service. - * - * Category: cloud,messaging,streams - * Since: 2.17 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * @return the dsl builder - */ - @Deprecated - static AwsDdbstreamComponentBuilder awsDdbstream() { - return new AwsDdbstreamComponentBuilderImpl(); - } - - /** - * Builder for the AWS DynamoDB Streams component. - */ - interface AwsDdbstreamComponentBuilder - 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 - * - * @param autoDiscoverClient the value to set - * @return the dsl builder - */ - 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: - * <code>com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams</code> type. - * - * Group: consumer - * - * @param amazonDynamoDbStreamsClient the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder amazonDynamoDbStreamsClient( - com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams amazonDynamoDbStreamsClient) { - doSetProperty("amazonDynamoDbStreamsClient", amazonDynamoDbStreamsClient); - return this; - } - /** - * 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. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: consumer - * - * @param bridgeErrorHandler the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder bridgeErrorHandler( - boolean bridgeErrorHandler) { - doSetProperty("bridgeErrorHandler", bridgeErrorHandler); - return this; - } - /** - * The component configuration. - * - * The option is a: - * <code>org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration</code> type. - * - * Group: consumer - * - * @param configuration the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder configuration( - org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration configuration) { - doSetProperty("configuration", configuration); - return this; - } - /** - * 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 option is a: - * <code>com.amazonaws.services.dynamodbv2.model.ShardIteratorType</code> type. - * - * Default: LATEST - * Group: consumer - * - * @param iteratorType the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder iteratorType( - com.amazonaws.services.dynamodbv2.model.ShardIteratorType iteratorType) { - doSetProperty("iteratorType", iteratorType); - return this; - } - /** - * Maximum number of records that will be fetched in each poll. - * - * The option is a: <code>int</code> type. - * - * Group: consumer - * - * @param maxResultsPerRequest the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder maxResultsPerRequest( - int maxResultsPerRequest) { - doSetProperty("maxResultsPerRequest", maxResultsPerRequest); - return this; - } - /** - * To define a proxy host when instantiating the DDBStreams client. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: consumer - * - * @param proxyHost the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder proxyHost( - java.lang.String proxyHost) { - doSetProperty("proxyHost", proxyHost); - return this; - } - /** - * To define a proxy port when instantiating the DDBStreams client. - * - * The option is a: <code>java.lang.Integer</code> type. - * - * Group: consumer - * - * @param proxyPort the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder proxyPort( - java.lang.Integer proxyPort) { - doSetProperty("proxyPort", proxyPort); - return this; - } - /** - * To define a proxy protocol when instantiating the DDBStreams client. - * - * The option is a: <code>com.amazonaws.Protocol</code> - * type. - * - * Default: HTTPS - * Group: consumer - * - * @param proxyProtocol the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder proxyProtocol( - com.amazonaws.Protocol proxyProtocol) { - doSetProperty("proxyProtocol", proxyProtocol); - return this; - } - /** - * The region in which DDBStreams client needs to work. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: consumer - * - * @param region the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder region(java.lang.String region) { - doSetProperty("region", region); - return this; - } - /** - * Provider for the sequence number when using one of the two - * ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER iterator types. Can be a - * registry reference or a literal sequence number. - * - * The option is a: - * <code>org.apache.camel.component.aws.ddbstream.SequenceNumberProvider</code> type. - * - * Group: consumer - * - * @param sequenceNumberProvider the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder sequenceNumberProvider( - org.apache.camel.component.aws.ddbstream.SequenceNumberProvider sequenceNumberProvider) { - doSetProperty("sequenceNumberProvider", sequenceNumberProvider); - return this; - } - /** - * Whether autowiring is enabled. This is used for automatic autowiring - * options (the option must be marked as autowired) by looking up in the - * registry to find if there is a single instance of matching type, - * which then gets configured on the component. This can be used for - * automatic configuring JDBC data sources, JMS connection factories, - * AWS Clients, etc. - * - * The option is a: <code>boolean</code> type. - * - * Default: true - * Group: advanced - * - * @param autowiredEnabled the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder autowiredEnabled( - boolean autowiredEnabled) { - doSetProperty("autowiredEnabled", autowiredEnabled); - return this; - } - /** - * Amazon AWS Access Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param accessKey the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder accessKey( - java.lang.String accessKey) { - doSetProperty("accessKey", accessKey); - return this; - } - /** - * Amazon AWS Secret Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param secretKey the value to set - * @return the dsl builder - */ - default AwsDdbstreamComponentBuilder secretKey( - java.lang.String secretKey) { - doSetProperty("secretKey", secretKey); - return this; - } - } - - class AwsDdbstreamComponentBuilderImpl - extends - AbstractComponentBuilder<DdbStreamComponent> - implements - AwsDdbstreamComponentBuilder { - @Override - protected DdbStreamComponent buildConcreteComponent() { - return new DdbStreamComponent(); - } - private org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration getOrCreateConfiguration( - org.apache.camel.component.aws.ddbstream.DdbStreamComponent component) { - if (component.getConfiguration() == null) { - component.setConfiguration(new org.apache.camel.component.aws.ddbstream.DdbStreamConfiguration()); - } - return component.getConfiguration(); - } - @Override - protected boolean setPropertyOnComponent( - Component component, - 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; - case "iteratorType": getOrCreateConfiguration((DdbStreamComponent) component).setIteratorType((com.amazonaws.services.dynamodbv2.model.ShardIteratorType) value); return true; - case "maxResultsPerRequest": getOrCreateConfiguration((DdbStreamComponent) component).setMaxResultsPerRequest((int) value); return true; - case "proxyHost": getOrCreateConfiguration((DdbStreamComponent) component).setProxyHost((java.lang.String) value); return true; - case "proxyPort": getOrCreateConfiguration((DdbStreamComponent) component).setProxyPort((java.lang.Integer) value); return true; - case "proxyProtocol": getOrCreateConfiguration((DdbStreamComponent) component).setProxyProtocol((com.amazonaws.Protocol) value); return true; - case "region": getOrCreateConfiguration((DdbStreamComponent) component).setRegion((java.lang.String) value); return true; - case "sequenceNumberProvider": getOrCreateConfiguration((DdbStreamComponent) component).setSequenceNumberProvider((org.apache.camel.component.aws.ddbstream.SequenceNumberProvider) value); return true; - case "autowiredEnabled": ((DdbStreamComponent) component).setAutowiredEnabled((boolean) value); return true; - case "accessKey": getOrCreateConfiguration((DdbStreamComponent) component).setAccessKey((java.lang.String) value); return true; - case "secretKey": getOrCreateConfiguration((DdbStreamComponent) component).setSecretKey((java.lang.String) value); return true; - default: return false; - } - } - } -} \ No newline at end of file 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 d35e8c7..ec23280 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 @@ -1877,96 +1877,6 @@ public class StaticEndpointBuilders { return org.apache.camel.builder.endpoint.dsl.CwEndpointBuilderFactory.endpointBuilder(componentName, path); } /** - * AWS DynamoDB (camel-aws-ddb) - * Store and retrieve data from AWS DynamoDB service. - * - * Category: cloud,database,nosql - * Since: 2.10 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddb:tableName</code> - * - * Path parameter: tableName (required) - * The name of the table currently worked with. - * - * @param path tableName - * @return the dsl builder - */ - @Deprecated - public static org.apache.camel.builder.endpoint.dsl.DdbEndpointBuilderFactory.DdbEndpointBuilder awsDdb( - String path) { - return org.apache.camel.builder.endpoint.dsl.DdbEndpointBuilderFactory.endpointBuilder("aws-ddb", path); - } - /** - * AWS DynamoDB (camel-aws-ddb) - * Store and retrieve data from AWS DynamoDB service. - * - * Category: cloud,database,nosql - * Since: 2.10 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddb:tableName</code> - * - * Path parameter: tableName (required) - * The name of the table currently worked with. - * - * @param componentName to use a custom component name for the endpoint - * instead of the default name - * @param path tableName - * @return the dsl builder - */ - @Deprecated - public static org.apache.camel.builder.endpoint.dsl.DdbEndpointBuilderFactory.DdbEndpointBuilder awsDdb( - String componentName, - String path) { - return org.apache.camel.builder.endpoint.dsl.DdbEndpointBuilderFactory.endpointBuilder(componentName, path); - } - /** - * AWS DynamoDB Streams (camel-aws-ddb) - * Receive messages from AWS DynamoDB Stream service. - * - * Category: cloud,messaging,streams - * Since: 2.17 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddbstream:tableName</code> - * - * Path parameter: tableName (required) - * Name of the dynamodb table - * - * @param path tableName - * @return the dsl builder - */ - @Deprecated - public static org.apache.camel.builder.endpoint.dsl.DdbStreamEndpointBuilderFactory.DdbStreamEndpointBuilder awsDdbstream( - String path) { - return org.apache.camel.builder.endpoint.dsl.DdbStreamEndpointBuilderFactory.endpointBuilder("aws-ddbstream", path); - } - /** - * AWS DynamoDB Streams (camel-aws-ddb) - * Receive messages from AWS DynamoDB Stream service. - * - * Category: cloud,messaging,streams - * Since: 2.17 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddbstream:tableName</code> - * - * Path parameter: tableName (required) - * Name of the dynamodb table - * - * @param componentName to use a custom component name for the endpoint - * instead of the default name - * @param path tableName - * @return the dsl builder - */ - @Deprecated - public static org.apache.camel.builder.endpoint.dsl.DdbStreamEndpointBuilderFactory.DdbStreamEndpointBuilder awsDdbstream( - String componentName, - String path) { - return org.apache.camel.builder.endpoint.dsl.DdbStreamEndpointBuilderFactory.endpointBuilder(componentName, path); - } - /** * AWS S3 Storage Service (camel-aws-s3) * Store and retrieve objects from AWS S3 Storage Service. * @@ -16622,4 +16532,4 @@ public class StaticEndpointBuilders { return org.apache.camel.builder.endpoint.dsl.ZooKeeperMasterEndpointBuilderFactory.endpointBuilder(componentName, path); } } -//CHECKSTYLE:ON \ No newline at end of file +//CHECKSTYLE:ON diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbEndpointBuilderFactory.java deleted file mode 100644 index c61dfdc..0000000 --- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbEndpointBuilderFactory.java +++ /dev/null @@ -1,507 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.builder.endpoint.dsl; - -import javax.annotation.Generated; -import org.apache.camel.builder.EndpointConsumerBuilder; -import org.apache.camel.builder.EndpointProducerBuilder; -import org.apache.camel.builder.endpoint.AbstractEndpointBuilder; - -/** - * Store and retrieve data from AWS DynamoDB service. - * - * Generated by camel build tools - do NOT edit this file! - */ -@Generated("org.apache.camel.maven.packaging.EndpointDslMojo") -public interface DdbEndpointBuilderFactory { - - - /** - * Builder for endpoint for the AWS DynamoDB component. - */ - public interface DdbEndpointBuilder extends EndpointProducerBuilder { - /** - * To use the AmazonDynamoDB as the client. - * - * The option is a: - * <code>com.amazonaws.services.dynamodbv2.AmazonDynamoDB</code> type. - * - * Group: producer - * - * @param amazonDDBClient the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder amazonDDBClient(Object amazonDDBClient) { - doSetProperty("amazonDDBClient", amazonDDBClient); - return this; - } - /** - * To use the AmazonDynamoDB as the client. - * - * The option will be converted to a - * <code>com.amazonaws.services.dynamodbv2.AmazonDynamoDB</code> type. - * - * Group: producer - * - * @param amazonDDBClient the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder amazonDDBClient(String amazonDDBClient) { - doSetProperty("amazonDDBClient", amazonDDBClient); - 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 - * - * @param autoDiscoverClient the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder 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 - * - * @param autoDiscoverClient the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder autoDiscoverClient(String autoDiscoverClient) { - doSetProperty("autoDiscoverClient", autoDiscoverClient); - return this; - } - /** - * Determines whether or not strong consistency should be enforced when - * data is read. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: producer - * - * @param consistentRead the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder consistentRead(boolean consistentRead) { - doSetProperty("consistentRead", consistentRead); - return this; - } - /** - * Determines whether or not strong consistency should be enforced when - * data is read. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: producer - * - * @param consistentRead the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder consistentRead(String consistentRead) { - doSetProperty("consistentRead", consistentRead); - return this; - } - /** - * Attribute name when creating table. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param keyAttributeName the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder keyAttributeName(String keyAttributeName) { - doSetProperty("keyAttributeName", keyAttributeName); - return this; - } - /** - * Attribute type when creating table. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param keyAttributeType the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder keyAttributeType(String keyAttributeType) { - doSetProperty("keyAttributeType", keyAttributeType); - 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 - * 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 starting the - * producer may take a little time and prolong the total processing time - * of the processing. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: producer - * - * @param lazyStartProducer the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder lazyStartProducer(boolean lazyStartProducer) { - doSetProperty("lazyStartProducer", lazyStartProducer); - 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 - * 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 starting the - * producer may take a little time and prolong the total processing time - * of the processing. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: producer - * - * @param lazyStartProducer the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder lazyStartProducer(String lazyStartProducer) { - doSetProperty("lazyStartProducer", lazyStartProducer); - return this; - } - /** - * What operation to perform. - * - * The option is a: - * <code>org.apache.camel.component.aws.ddb.DdbOperations</code> type. - * - * Default: PutItem - * Group: producer - * - * @param operation the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder operation(DdbOperations operation) { - doSetProperty("operation", operation); - return this; - } - /** - * What operation to perform. - * - * The option will be converted to a - * <code>org.apache.camel.component.aws.ddb.DdbOperations</code> type. - * - * Default: PutItem - * Group: producer - * - * @param operation the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder operation(String operation) { - doSetProperty("operation", operation); - return this; - } - /** - * To define a proxy host when instantiating the DDB client. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param proxyHost the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder proxyHost(String proxyHost) { - doSetProperty("proxyHost", proxyHost); - return this; - } - /** - * To define a proxy port when instantiating the DDB client. 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(). - * - * The option is a: <code>java.lang.Integer</code> type. - * - * Group: producer - * - * @param proxyPort the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder proxyPort(Integer proxyPort) { - doSetProperty("proxyPort", proxyPort); - return this; - } - /** - * To define a proxy port when instantiating the DDB client. 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(). - * - * The option will be converted to a - * <code>java.lang.Integer</code> type. - * - * Group: producer - * - * @param proxyPort the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder proxyPort(String proxyPort) { - doSetProperty("proxyPort", proxyPort); - return this; - } - /** - * To define a proxy protocol when instantiating the DDB client. - * - * The option is a: <code>com.amazonaws.Protocol</code> - * type. - * - * Default: HTTPS - * Group: producer - * - * @param proxyProtocol the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder proxyProtocol(Protocol proxyProtocol) { - doSetProperty("proxyProtocol", proxyProtocol); - return this; - } - /** - * To define a proxy protocol when instantiating the DDB client. - * - * The option will be converted to a - * <code>com.amazonaws.Protocol</code> type. - * - * Default: HTTPS - * Group: producer - * - * @param proxyProtocol the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder proxyProtocol(String proxyProtocol) { - doSetProperty("proxyProtocol", proxyProtocol); - return this; - } - /** - * The provisioned throughput to reserve for reading resources from your - * table. - * - * The option is a: <code>java.lang.Long</code> type. - * - * Group: producer - * - * @param readCapacity the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder readCapacity(Long readCapacity) { - doSetProperty("readCapacity", readCapacity); - return this; - } - /** - * The provisioned throughput to reserve for reading resources from your - * table. - * - * The option will be converted to a - * <code>java.lang.Long</code> type. - * - * Group: producer - * - * @param readCapacity the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder readCapacity(String readCapacity) { - doSetProperty("readCapacity", readCapacity); - return this; - } - /** - * The region in which DDB client needs to work. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: producer - * - * @param region the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder region(String region) { - doSetProperty("region", region); - return this; - } - /** - * The provisioned throughput to reserved for writing resources to your - * table. - * - * The option is a: <code>java.lang.Long</code> type. - * - * Group: producer - * - * @param writeCapacity the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder writeCapacity(Long writeCapacity) { - doSetProperty("writeCapacity", writeCapacity); - return this; - } - /** - * The provisioned throughput to reserved for writing resources to your - * table. - * - * The option will be converted to a - * <code>java.lang.Long</code> type. - * - * Group: producer - * - * @param writeCapacity the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder writeCapacity(String writeCapacity) { - doSetProperty("writeCapacity", writeCapacity); - return this; - } - /** - * Amazon AWS Access Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param accessKey the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder accessKey(String accessKey) { - doSetProperty("accessKey", accessKey); - return this; - } - /** - * Amazon AWS Secret Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param secretKey the value to set - * @return the dsl builder - */ - default DdbEndpointBuilder secretKey(String secretKey) { - doSetProperty("secretKey", secretKey); - return this; - } - } - - /** - * Proxy enum for - * <code>org.apache.camel.component.aws.ddb.DdbOperations</code> enum. - */ - enum DdbOperations { - BatchGetItems, - DeleteItem, - DeleteTable, - DescribeTable, - GetItem, - PutItem, - Query, - Scan, - UpdateItem, - UpdateTable; - } - - /** - * Proxy enum for <code>com.amazonaws.Protocol</code> enum. - */ - enum Protocol { - HTTP, - HTTPS; - } - - public interface DdbBuilders { - /** - * AWS DynamoDB (camel-aws-ddb) - * Store and retrieve data from AWS DynamoDB service. - * - * Category: cloud,database,nosql - * Since: 2.10 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddb:tableName</code> - * - * Path parameter: tableName (required) - * The name of the table currently worked with. - * - * @param path tableName - * @return the dsl builder - */ - @Deprecated - default DdbEndpointBuilder awsDdb(String path) { - return DdbEndpointBuilderFactory.endpointBuilder("aws-ddb", path); - } - /** - * AWS DynamoDB (camel-aws-ddb) - * Store and retrieve data from AWS DynamoDB service. - * - * Category: cloud,database,nosql - * Since: 2.10 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddb:tableName</code> - * - * Path parameter: tableName (required) - * The name of the table currently worked with. - * - * @param componentName to use a custom component name for the endpoint - * instead of the default name - * @param path tableName - * @return the dsl builder - */ - @Deprecated - default DdbEndpointBuilder awsDdb(String componentName, String path) { - return DdbEndpointBuilderFactory.endpointBuilder(componentName, path); - } - } - @Deprecated - static DdbEndpointBuilder endpointBuilder(String componentName, String path) { - class DdbEndpointBuilderImpl extends AbstractEndpointBuilder implements DdbEndpointBuilder { - public DdbEndpointBuilderImpl(String path) { - super(componentName, path); - } - } - return new DdbEndpointBuilderImpl(path); - } -} \ No newline at end of file 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 deleted file mode 100644 index 5ec9b84..0000000 --- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/DdbStreamEndpointBuilderFactory.java +++ /dev/null @@ -1,1087 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one or more - * contributor license agreements. See the NOTICE file distributed with - * this work for additional information regarding copyright ownership. - * The ASF licenses this file to You under the Apache License, Version 2.0 - * (the "License"); you may not use this file except in compliance with - * the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.camel.builder.endpoint.dsl; - -import java.util.Map; -import java.util.concurrent.ScheduledExecutorService; -import java.util.concurrent.TimeUnit; -import javax.annotation.Generated; -import org.apache.camel.ExchangePattern; -import org.apache.camel.LoggingLevel; -import org.apache.camel.builder.EndpointConsumerBuilder; -import org.apache.camel.builder.EndpointProducerBuilder; -import org.apache.camel.builder.endpoint.AbstractEndpointBuilder; -import org.apache.camel.spi.ExceptionHandler; -import org.apache.camel.spi.PollingConsumerPollStrategy; - -/** - * Receive messages from AWS DynamoDB Stream service. - * - * Generated by camel build tools - do NOT edit this file! - */ -@Generated("org.apache.camel.maven.packaging.EndpointDslMojo") -public interface DdbStreamEndpointBuilderFactory { - - - /** - * Builder for endpoint for the AWS DynamoDB Streams component. - */ - public interface DdbStreamEndpointBuilder extends EndpointConsumerBuilder { - default AdvancedDdbStreamEndpointBuilder advanced() { - 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 - * - * @param autoDiscoverClient the value to set - * @return the dsl builder - */ - 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 - * - * @param autoDiscoverClient the value to set - * @return the dsl builder - */ - 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: - * <code>com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams</code> type. - * - * Group: consumer - * - * @param amazonDynamoDbStreamsClient the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder amazonDynamoDbStreamsClient( - Object amazonDynamoDbStreamsClient) { - doSetProperty("amazonDynamoDbStreamsClient", amazonDynamoDbStreamsClient); - return this; - } - /** - * Amazon DynamoDB client to use for all requests for this endpoint. - * - * The option will be converted to a - * <code>com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams</code> type. - * - * Group: consumer - * - * @param amazonDynamoDbStreamsClient the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder amazonDynamoDbStreamsClient( - String amazonDynamoDbStreamsClient) { - doSetProperty("amazonDynamoDbStreamsClient", amazonDynamoDbStreamsClient); - return this; - } - /** - * 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. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: consumer - * - * @param bridgeErrorHandler the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder bridgeErrorHandler( - boolean bridgeErrorHandler) { - doSetProperty("bridgeErrorHandler", bridgeErrorHandler); - return this; - } - /** - * 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. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: consumer - * - * @param bridgeErrorHandler the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder bridgeErrorHandler( - String bridgeErrorHandler) { - doSetProperty("bridgeErrorHandler", bridgeErrorHandler); - return this; - } - /** - * 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 option is a: - * <code>com.amazonaws.services.dynamodbv2.model.ShardIteratorType</code> type. - * - * Default: LATEST - * Group: consumer - * - * @param iteratorType the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder iteratorType( - ShardIteratorType iteratorType) { - doSetProperty("iteratorType", iteratorType); - return this; - } - /** - * 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 option will be converted to a - * <code>com.amazonaws.services.dynamodbv2.model.ShardIteratorType</code> type. - * - * Default: LATEST - * Group: consumer - * - * @param iteratorType the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder iteratorType(String iteratorType) { - doSetProperty("iteratorType", iteratorType); - return this; - } - /** - * Maximum number of records that will be fetched in each poll. - * - * The option is a: <code>int</code> type. - * - * Group: consumer - * - * @param maxResultsPerRequest the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder maxResultsPerRequest( - int maxResultsPerRequest) { - doSetProperty("maxResultsPerRequest", maxResultsPerRequest); - return this; - } - /** - * Maximum number of records that will be fetched in each poll. - * - * The option will be converted to a <code>int</code> type. - * - * Group: consumer - * - * @param maxResultsPerRequest the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder maxResultsPerRequest( - String maxResultsPerRequest) { - doSetProperty("maxResultsPerRequest", maxResultsPerRequest); - return this; - } - /** - * To define a proxy host when instantiating the DDBStreams client. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: consumer - * - * @param proxyHost the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder proxyHost(String proxyHost) { - doSetProperty("proxyHost", proxyHost); - return this; - } - /** - * To define a proxy port when instantiating the DDBStreams client. - * - * The option is a: <code>java.lang.Integer</code> type. - * - * Group: consumer - * - * @param proxyPort the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder proxyPort(Integer proxyPort) { - doSetProperty("proxyPort", proxyPort); - return this; - } - /** - * To define a proxy port when instantiating the DDBStreams client. - * - * The option will be converted to a - * <code>java.lang.Integer</code> type. - * - * Group: consumer - * - * @param proxyPort the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder proxyPort(String proxyPort) { - doSetProperty("proxyPort", proxyPort); - return this; - } - /** - * To define a proxy protocol when instantiating the DDBStreams client. - * - * The option is a: <code>com.amazonaws.Protocol</code> - * type. - * - * Default: HTTPS - * Group: consumer - * - * @param proxyProtocol the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder proxyProtocol(Protocol proxyProtocol) { - doSetProperty("proxyProtocol", proxyProtocol); - return this; - } - /** - * To define a proxy protocol when instantiating the DDBStreams client. - * - * The option will be converted to a - * <code>com.amazonaws.Protocol</code> type. - * - * Default: HTTPS - * Group: consumer - * - * @param proxyProtocol the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder proxyProtocol(String proxyProtocol) { - doSetProperty("proxyProtocol", proxyProtocol); - return this; - } - /** - * The region in which DDBStreams client needs to work. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: consumer - * - * @param region the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder region(String region) { - doSetProperty("region", region); - return this; - } - /** - * If the polling consumer did not poll any files, you can enable this - * option to send an empty message (no body) instead. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: consumer - * - * @param sendEmptyMessageWhenIdle the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder sendEmptyMessageWhenIdle( - boolean sendEmptyMessageWhenIdle) { - doSetProperty("sendEmptyMessageWhenIdle", sendEmptyMessageWhenIdle); - return this; - } - /** - * If the polling consumer did not poll any files, you can enable this - * option to send an empty message (no body) instead. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: consumer - * - * @param sendEmptyMessageWhenIdle the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder sendEmptyMessageWhenIdle( - String sendEmptyMessageWhenIdle) { - doSetProperty("sendEmptyMessageWhenIdle", sendEmptyMessageWhenIdle); - return this; - } - /** - * Provider for the sequence number when using one of the two - * ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER iterator types. Can be a - * registry reference or a literal sequence number. - * - * The option is a: - * <code>org.apache.camel.component.aws.ddbstream.SequenceNumberProvider</code> type. - * - * Group: consumer - * - * @param sequenceNumberProvider the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder sequenceNumberProvider( - Object sequenceNumberProvider) { - doSetProperty("sequenceNumberProvider", sequenceNumberProvider); - return this; - } - /** - * Provider for the sequence number when using one of the two - * ShardIteratorType.{AT,AFTER}_SEQUENCE_NUMBER iterator types. Can be a - * registry reference or a literal sequence number. - * - * The option will be converted to a - * <code>org.apache.camel.component.aws.ddbstream.SequenceNumberProvider</code> type. - * - * Group: consumer - * - * @param sequenceNumberProvider the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder sequenceNumberProvider( - String sequenceNumberProvider) { - doSetProperty("sequenceNumberProvider", sequenceNumberProvider); - return this; - } - /** - * The number of subsequent error polls (failed due some error) that - * should happen before the backoffMultipler should kick-in. - * - * The option is a: <code>int</code> type. - * - * Group: scheduler - * - * @param backoffErrorThreshold the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder backoffErrorThreshold( - int backoffErrorThreshold) { - doSetProperty("backoffErrorThreshold", backoffErrorThreshold); - return this; - } - /** - * The number of subsequent error polls (failed due some error) that - * should happen before the backoffMultipler should kick-in. - * - * The option will be converted to a <code>int</code> type. - * - * Group: scheduler - * - * @param backoffErrorThreshold the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder backoffErrorThreshold( - String backoffErrorThreshold) { - doSetProperty("backoffErrorThreshold", backoffErrorThreshold); - return this; - } - /** - * The number of subsequent idle polls that should happen before the - * backoffMultipler should kick-in. - * - * The option is a: <code>int</code> type. - * - * Group: scheduler - * - * @param backoffIdleThreshold the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder backoffIdleThreshold( - int backoffIdleThreshold) { - doSetProperty("backoffIdleThreshold", backoffIdleThreshold); - return this; - } - /** - * The number of subsequent idle polls that should happen before the - * backoffMultipler should kick-in. - * - * The option will be converted to a <code>int</code> type. - * - * Group: scheduler - * - * @param backoffIdleThreshold the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder backoffIdleThreshold( - String backoffIdleThreshold) { - doSetProperty("backoffIdleThreshold", backoffIdleThreshold); - return this; - } - /** - * To let the scheduled polling consumer backoff if there has been a - * number of subsequent idles/errors in a row. The multiplier is then - * the number of polls that will be skipped before the next actual - * attempt is happening again. When this option is in use then - * backoffIdleThreshold and/or backoffErrorThreshold must also be - * configured. - * - * The option is a: <code>int</code> type. - * - * Group: scheduler - * - * @param backoffMultiplier the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder backoffMultiplier(int backoffMultiplier) { - doSetProperty("backoffMultiplier", backoffMultiplier); - return this; - } - /** - * To let the scheduled polling consumer backoff if there has been a - * number of subsequent idles/errors in a row. The multiplier is then - * the number of polls that will be skipped before the next actual - * attempt is happening again. When this option is in use then - * backoffIdleThreshold and/or backoffErrorThreshold must also be - * configured. - * - * The option will be converted to a <code>int</code> type. - * - * Group: scheduler - * - * @param backoffMultiplier the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder backoffMultiplier( - String backoffMultiplier) { - doSetProperty("backoffMultiplier", backoffMultiplier); - return this; - } - /** - * Milliseconds before the next poll. - * - * The option is a: <code>long</code> type. - * - * Default: 500 - * Group: scheduler - * - * @param delay the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder delay(long delay) { - doSetProperty("delay", delay); - return this; - } - /** - * Milliseconds before the next poll. - * - * The option will be converted to a <code>long</code> type. - * - * Default: 500 - * Group: scheduler - * - * @param delay the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder delay(String delay) { - doSetProperty("delay", delay); - return this; - } - /** - * If greedy is enabled, then the ScheduledPollConsumer will run - * immediately again, if the previous run polled 1 or more messages. - * - * The option is a: <code>boolean</code> type. - * - * Default: false - * Group: scheduler - * - * @param greedy the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder greedy(boolean greedy) { - doSetProperty("greedy", greedy); - return this; - } - /** - * If greedy is enabled, then the ScheduledPollConsumer will run - * immediately again, if the previous run polled 1 or more messages. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: false - * Group: scheduler - * - * @param greedy the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder greedy(String greedy) { - doSetProperty("greedy", greedy); - return this; - } - /** - * Milliseconds before the first poll starts. - * - * The option is a: <code>long</code> type. - * - * Default: 1000 - * Group: scheduler - * - * @param initialDelay the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder initialDelay(long initialDelay) { - doSetProperty("initialDelay", initialDelay); - return this; - } - /** - * Milliseconds before the first poll starts. - * - * The option will be converted to a <code>long</code> type. - * - * Default: 1000 - * Group: scheduler - * - * @param initialDelay the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder initialDelay(String initialDelay) { - doSetProperty("initialDelay", initialDelay); - return this; - } - /** - * Specifies a maximum limit of number of fires. So if you set it to 1, - * the scheduler will only fire once. If you set it to 5, it will only - * fire five times. A value of zero or negative means fire forever. - * - * The option is a: <code>long</code> type. - * - * Default: 0 - * Group: scheduler - * - * @param repeatCount the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder repeatCount(long repeatCount) { - doSetProperty("repeatCount", repeatCount); - return this; - } - /** - * Specifies a maximum limit of number of fires. So if you set it to 1, - * the scheduler will only fire once. If you set it to 5, it will only - * fire five times. A value of zero or negative means fire forever. - * - * The option will be converted to a <code>long</code> type. - * - * Default: 0 - * Group: scheduler - * - * @param repeatCount the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder repeatCount(String repeatCount) { - doSetProperty("repeatCount", repeatCount); - return this; - } - /** - * The consumer logs a start/complete log line when it polls. This - * option allows you to configure the logging level for that. - * - * The option is a: - * <code>org.apache.camel.LoggingLevel</code> type. - * - * Default: TRACE - * Group: scheduler - * - * @param runLoggingLevel the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder runLoggingLevel( - LoggingLevel runLoggingLevel) { - doSetProperty("runLoggingLevel", runLoggingLevel); - return this; - } - /** - * The consumer logs a start/complete log line when it polls. This - * option allows you to configure the logging level for that. - * - * The option will be converted to a - * <code>org.apache.camel.LoggingLevel</code> type. - * - * Default: TRACE - * Group: scheduler - * - * @param runLoggingLevel the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder runLoggingLevel(String runLoggingLevel) { - doSetProperty("runLoggingLevel", runLoggingLevel); - return this; - } - /** - * Allows for configuring a custom/shared thread pool to use for the - * consumer. By default each consumer has its own single threaded thread - * pool. - * - * The option is a: - * <code>java.util.concurrent.ScheduledExecutorService</code> type. - * - * Group: scheduler - * - * @param scheduledExecutorService the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder scheduledExecutorService( - ScheduledExecutorService scheduledExecutorService) { - doSetProperty("scheduledExecutorService", scheduledExecutorService); - return this; - } - /** - * Allows for configuring a custom/shared thread pool to use for the - * consumer. By default each consumer has its own single threaded thread - * pool. - * - * The option will be converted to a - * <code>java.util.concurrent.ScheduledExecutorService</code> type. - * - * Group: scheduler - * - * @param scheduledExecutorService the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder scheduledExecutorService( - String scheduledExecutorService) { - doSetProperty("scheduledExecutorService", scheduledExecutorService); - return this; - } - /** - * To use a cron scheduler from either camel-spring or camel-quartz - * component. Use value spring or quartz for built in scheduler. - * - * The option is a: <code>java.lang.Object</code> type. - * - * Default: none - * Group: scheduler - * - * @param scheduler the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder scheduler(Object scheduler) { - doSetProperty("scheduler", scheduler); - return this; - } - /** - * To use a cron scheduler from either camel-spring or camel-quartz - * component. Use value spring or quartz for built in scheduler. - * - * The option will be converted to a - * <code>java.lang.Object</code> type. - * - * Default: none - * Group: scheduler - * - * @param scheduler the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder scheduler(String scheduler) { - doSetProperty("scheduler", scheduler); - return this; - } - /** - * To configure additional properties when using a custom scheduler or - * any of the Quartz, Spring based scheduler. - * - * The option is a: <code>java.util.Map&lt;java.lang.String, - * java.lang.Object&gt;</code> type. - * The option is multivalued, and you can use the - * schedulerProperties(String, Object) method to add a value (call the - * method multiple times to set more values). - * - * Group: scheduler - * - * @param key the option key - * @param value the option value - * @return the dsl builder - */ - default DdbStreamEndpointBuilder schedulerProperties( - String key, - Object value) { - doSetMultiValueProperty("schedulerProperties", "scheduler." + key, value); - return this; - } - /** - * To configure additional properties when using a custom scheduler or - * any of the Quartz, Spring based scheduler. - * - * The option is a: <code>java.util.Map&lt;java.lang.String, - * java.lang.Object&gt;</code> type. - * The option is multivalued, and you can use the - * schedulerProperties(String, Object) method to add a value (call the - * method multiple times to set more values). - * - * Group: scheduler - * - * @param values the values - * @return the dsl builder - */ - default DdbStreamEndpointBuilder schedulerProperties(Map values) { - doSetMultiValueProperties("schedulerProperties", "scheduler.", values); - return this; - } - /** - * Whether the scheduler should be auto started. - * - * The option is a: <code>boolean</code> type. - * - * Default: true - * Group: scheduler - * - * @param startScheduler the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder startScheduler(boolean startScheduler) { - doSetProperty("startScheduler", startScheduler); - return this; - } - /** - * Whether the scheduler should be auto started. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: true - * Group: scheduler - * - * @param startScheduler the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder startScheduler(String startScheduler) { - doSetProperty("startScheduler", startScheduler); - return this; - } - /** - * Time unit for initialDelay and delay options. - * - * The option is a: - * <code>java.util.concurrent.TimeUnit</code> type. - * - * Default: MILLISECONDS - * Group: scheduler - * - * @param timeUnit the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder timeUnit(TimeUnit timeUnit) { - doSetProperty("timeUnit", timeUnit); - return this; - } - /** - * Time unit for initialDelay and delay options. - * - * The option will be converted to a - * <code>java.util.concurrent.TimeUnit</code> type. - * - * Default: MILLISECONDS - * Group: scheduler - * - * @param timeUnit the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder timeUnit(String timeUnit) { - doSetProperty("timeUnit", timeUnit); - return this; - } - /** - * Controls if fixed delay or fixed rate is used. See - * ScheduledExecutorService in JDK for details. - * - * The option is a: <code>boolean</code> type. - * - * Default: true - * Group: scheduler - * - * @param useFixedDelay the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder useFixedDelay(boolean useFixedDelay) { - doSetProperty("useFixedDelay", useFixedDelay); - return this; - } - /** - * Controls if fixed delay or fixed rate is used. See - * ScheduledExecutorService in JDK for details. - * - * The option will be converted to a <code>boolean</code> - * type. - * - * Default: true - * Group: scheduler - * - * @param useFixedDelay the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder useFixedDelay(String useFixedDelay) { - doSetProperty("useFixedDelay", useFixedDelay); - return this; - } - /** - * Amazon AWS Access Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param accessKey the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder accessKey(String accessKey) { - doSetProperty("accessKey", accessKey); - return this; - } - /** - * Amazon AWS Secret Key. - * - * The option is a: <code>java.lang.String</code> type. - * - * Group: security - * - * @param secretKey the value to set - * @return the dsl builder - */ - default DdbStreamEndpointBuilder secretKey(String secretKey) { - doSetProperty("secretKey", secretKey); - return this; - } - } - - /** - * Advanced builder for endpoint for the AWS DynamoDB Streams component. - */ - public interface AdvancedDdbStreamEndpointBuilder - extends - EndpointConsumerBuilder { - default DdbStreamEndpointBuilder basic() { - return (DdbStreamEndpointBuilder) this; - } - /** - * To let the consumer use a custom ExceptionHandler. Notice if the - * option bridgeErrorHandler is enabled then this option is not in use. - * By default the consumer will deal with exceptions, that will be - * logged at WARN or ERROR level and ignored. - * - * The option is a: - * <code>org.apache.camel.spi.ExceptionHandler</code> type. - * - * Group: consumer (advanced) - * - * @param exceptionHandler the value to set - * @return the dsl builder - */ - default AdvancedDdbStreamEndpointBuilder exceptionHandler( - ExceptionHandler exceptionHandler) { - doSetProperty("exceptionHandler", exceptionHandler); - return this; - } - /** - * To let the consumer use a custom ExceptionHandler. Notice if the - * option bridgeErrorHandler is enabled then this option is not in use. - * By default the consumer will deal with exceptions, that will be - * logged at WARN or ERROR level and ignored. - * - * The option will be converted to a - * <code>org.apache.camel.spi.ExceptionHandler</code> type. - * - * Group: consumer (advanced) - * - * @param exceptionHandler the value to set - * @return the dsl builder - */ - default AdvancedDdbStreamEndpointBuilder exceptionHandler( - String exceptionHandler) { - doSetProperty("exceptionHandler", exceptionHandler); - return this; - } - /** - * Sets the exchange pattern when the consumer creates an exchange. - * - * The option is a: - * <code>org.apache.camel.ExchangePattern</code> type. - * - * Group: consumer (advanced) - * - * @param exchangePattern the value to set - * @return the dsl builder - */ - default AdvancedDdbStreamEndpointBuilder exchangePattern( - ExchangePattern exchangePattern) { - doSetProperty("exchangePattern", exchangePattern); - return this; - } - /** - * Sets the exchange pattern when the consumer creates an exchange. - * - * The option will be converted to a - * <code>org.apache.camel.ExchangePattern</code> type. - * - * Group: consumer (advanced) - * - * @param exchangePattern the value to set - * @return the dsl builder - */ - default AdvancedDdbStreamEndpointBuilder exchangePattern( - String exchangePattern) { - doSetProperty("exchangePattern", exchangePattern); - return this; - } - /** - * A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing - * you to provide your custom implementation to control error handling - * usually occurred during the poll operation before an Exchange have - * been created and being routed in Camel. - * - * The option is a: - * <code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type. - * - * Group: consumer (advanced) - * - * @param pollStrategy the value to set - * @return the dsl builder - */ - default AdvancedDdbStreamEndpointBuilder pollStrategy( - PollingConsumerPollStrategy pollStrategy) { - doSetProperty("pollStrategy", pollStrategy); - return this; - } - /** - * A pluggable org.apache.camel.PollingConsumerPollingStrategy allowing - * you to provide your custom implementation to control error handling - * usually occurred during the poll operation before an Exchange have - * been created and being routed in Camel. - * - * The option will be converted to a - * <code>org.apache.camel.spi.PollingConsumerPollStrategy</code> type. - * - * Group: consumer (advanced) - * - * @param pollStrategy the value to set - * @return the dsl builder - */ - default AdvancedDdbStreamEndpointBuilder pollStrategy( - String pollStrategy) { - doSetProperty("pollStrategy", pollStrategy); - return this; - } - } - - /** - * Proxy enum for - * <code>com.amazonaws.services.dynamodbv2.model.ShardIteratorType</code> - * enum. - */ - enum ShardIteratorType { - TRIM_HORIZON, - LATEST, - AT_SEQUENCE_NUMBER, - AFTER_SEQUENCE_NUMBER; - } - - /** - * Proxy enum for <code>com.amazonaws.Protocol</code> enum. - */ - enum Protocol { - HTTP, - HTTPS; - } - - public interface DdbStreamBuilders { - /** - * AWS DynamoDB Streams (camel-aws-ddb) - * Receive messages from AWS DynamoDB Stream service. - * - * Category: cloud,messaging,streams - * Since: 2.17 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddbstream:tableName</code> - * - * Path parameter: tableName (required) - * Name of the dynamodb table - * - * @param path tableName - * @return the dsl builder - */ - @Deprecated - default DdbStreamEndpointBuilder awsDdbstream(String path) { - return DdbStreamEndpointBuilderFactory.endpointBuilder("aws-ddbstream", path); - } - /** - * AWS DynamoDB Streams (camel-aws-ddb) - * Receive messages from AWS DynamoDB Stream service. - * - * Category: cloud,messaging,streams - * Since: 2.17 - * Maven coordinates: org.apache.camel:camel-aws-ddb - * - * Syntax: <code>aws-ddbstream:tableName</code> - * - * Path parameter: tableName (required) - * Name of the dynamodb table - * - * @param componentName to use a custom component name for the endpoint - * instead of the default name - * @param path tableName - * @return the dsl builder - */ - @Deprecated - default DdbStreamEndpointBuilder awsDdbstream( - String componentName, - String path) { - return DdbStreamEndpointBuilderFactory.endpointBuilder(componentName, path); - } - } - @Deprecated - static DdbStreamEndpointBuilder endpointBuilder( - String componentName, - String path) { - class DdbStreamEndpointBuilderImpl extends AbstractEndpointBuilder implements DdbStreamEndpointBuilder, AdvancedDdbStreamEndpointBuilder { - public DdbStreamEndpointBuilderImpl(String path) { - super(componentName, path); - } - } - return new DdbStreamEndpointBuilderImpl(path); - } -} \ No newline at end of file
