You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2021/02/22 17:46:30 UTC
[camel] 03/06: CAMEL-16115 - Remove Camel-AWS-* components -
AWS-Kinesis
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 840cce6957b6f948338dfe05adfb192b65472405
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Feb 22 16:43:59 2021 +0100
CAMEL-16115 - Remove Camel-AWS-* components - AWS-Kinesis
---
.../component/ComponentsBuilderFactory.java | 30 +-
.../dsl/AwsKinesisComponentBuilderFactory.java | 392 -----
.../AwsKinesisFirehoseComponentBuilderFactory.java | 287 ----
.../dsl/KinesisEndpointBuilderFactory.java | 1624 --------------------
.../dsl/KinesisFirehoseEndpointBuilderFactory.java | 353 -----
5 files changed, 1 insertion(+), 2685 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 6484207..f764739 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
@@ -404,34 +404,6 @@ public interface ComponentsBuilderFactory {
return org.apache.camel.builder.component.dsl.AwsIamComponentBuilderFactory.awsIam();
}
/**
- * AWS Kinesis (camel-aws-kinesis)
- * Consume and produce records from AWS Kinesis Streams.
- *
- * Category: cloud,messaging
- * Since: 2.17
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * @return the dsl builder
- */
- @Deprecated
- static org.apache.camel.builder.component.dsl.AwsKinesisComponentBuilderFactory.AwsKinesisComponentBuilder awsKinesis() {
- return org.apache.camel.builder.component.dsl.AwsKinesisComponentBuilderFactory.awsKinesis();
- }
- /**
- * AWS Kinesis Firehose (camel-aws-kinesis)
- * Consume data from AWS Kinesis Firehose streams.
- *
- * Category: cloud,messaging
- * Since: 2.19
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * @return the dsl builder
- */
- @Deprecated
- static org.apache.camel.builder.component.dsl.AwsKinesisFirehoseComponentBuilderFactory.AwsKinesisFirehoseComponentBuilder awsKinesisFirehose() {
- return org.apache.camel.builder.component.dsl.AwsKinesisFirehoseComponentBuilderFactory.awsKinesisFirehose();
- }
- /**
* AWS S3 Storage Service (camel-aws-s3)
* Store and retrieve objects from AWS S3 Storage Service.
*
@@ -4820,4 +4792,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/AwsKinesisComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsKinesisComponentBuilderFactory.java
deleted file mode 100644
index 0322ed9..0000000
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsKinesisComponentBuilderFactory.java
+++ /dev/null
@@ -1,392 +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.kinesis.KinesisComponent;
-
-/**
- * Consume and produce records from AWS Kinesis Streams.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface AwsKinesisComponentBuilderFactory {
-
- /**
- * AWS Kinesis (camel-aws-kinesis)
- * Consume and produce records from AWS Kinesis Streams.
- *
- * Category: cloud,messaging
- * Since: 2.17
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * @return the dsl builder
- */
- @Deprecated
- static AwsKinesisComponentBuilder awsKinesis() {
- return new AwsKinesisComponentBuilderImpl();
- }
-
- /**
- * Builder for the AWS Kinesis component.
- */
- interface AwsKinesisComponentBuilder
- extends
- ComponentBuilder<KinesisComponent> {
- /**
- * Amazon Kinesis client to use for all requests for this endpoint.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesis.AmazonKinesis</code>
- * type.
- *
- * Group: common
- *
- * @param amazonKinesisClient the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder amazonKinesisClient(
- com.amazonaws.services.kinesis.AmazonKinesis amazonKinesisClient) {
- doSetProperty("amazonKinesisClient", amazonKinesisClient);
- 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 AwsKinesisComponentBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * The component configuration.
- *
- * The option is a:
- * <code>org.apache.camel.component.aws.kinesis.KinesisConfiguration</code> type.
- *
- * Group: common
- *
- * @param configuration the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder configuration(
- org.apache.camel.component.aws.kinesis.KinesisConfiguration configuration) {
- doSetProperty("configuration", configuration);
- return this;
- }
- /**
- * To define a proxy host when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder proxyHost(java.lang.String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: common
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder proxyPort(java.lang.Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis client.
- *
- * The option is a: <code>com.amazonaws.Protocol</code>
- * type.
- *
- * Default: HTTPS
- * Group: common
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder proxyProtocol(
- com.amazonaws.Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which Kinesis client needs to work. 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.String</code> type.
- *
- * Group: common
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder region(java.lang.String region) {
- doSetProperty("region", region);
- 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 AwsKinesisComponentBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * Defines where in the Kinesis stream to start getting records.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesis.model.ShardIteratorType</code> type.
- *
- * Default: TRIM_HORIZON
- * Group: consumer
- *
- * @param iteratorType the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder iteratorType(
- com.amazonaws.services.kinesis.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.
- *
- * Default: 1
- * Group: consumer
- *
- * @param maxResultsPerRequest the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder maxResultsPerRequest(
- int maxResultsPerRequest) {
- doSetProperty("maxResultsPerRequest", maxResultsPerRequest);
- return this;
- }
- /**
- * The sequence number to start polling from. Required if iteratorType
- * is set to AFTER_SEQUENCE_NUMBER or AT_SEQUENCE_NUMBER.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- *
- * @param sequenceNumber the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder sequenceNumber(
- java.lang.String sequenceNumber) {
- doSetProperty("sequenceNumber", sequenceNumber);
- return this;
- }
- /**
- * Define what will be the behavior in case of shard closed. Possible
- * value are ignore, silent and fail. In case of ignore a message will
- * be logged and the consumer will restart from the beginning,in case of
- * silent there will be no logging and the consumer will start from the
- * beginning,in case of fail a ReachedClosedStateException will be
- * raised.
- *
- * The option is a:
- * <code>org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum</code> type.
- *
- * Default: ignore
- * Group: consumer
- *
- * @param shardClosed the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder shardClosed(
- org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum shardClosed) {
- doSetProperty("shardClosed", shardClosed);
- return this;
- }
- /**
- * Defines which shardId in the Kinesis stream to get records from.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- *
- * @param shardId the value to set
- * @return the dsl builder
- */
- default AwsKinesisComponentBuilder shardId(java.lang.String shardId) {
- doSetProperty("shardId", shardId);
- 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 AwsKinesisComponentBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- 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 AwsKinesisComponentBuilder 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 AwsKinesisComponentBuilder 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 AwsKinesisComponentBuilder secretKey(java.lang.String secretKey) {
- doSetProperty("secretKey", secretKey);
- return this;
- }
- }
-
- class AwsKinesisComponentBuilderImpl
- extends
- AbstractComponentBuilder<KinesisComponent>
- implements
- AwsKinesisComponentBuilder {
- @Override
- protected KinesisComponent buildConcreteComponent() {
- return new KinesisComponent();
- }
- private org.apache.camel.component.aws.kinesis.KinesisConfiguration getOrCreateConfiguration(
- org.apache.camel.component.aws.kinesis.KinesisComponent component) {
- if (component.getConfiguration() == null) {
- component.setConfiguration(new org.apache.camel.component.aws.kinesis.KinesisConfiguration());
- }
- return component.getConfiguration();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "amazonKinesisClient": getOrCreateConfiguration((KinesisComponent) component).setAmazonKinesisClient((com.amazonaws.services.kinesis.AmazonKinesis) value); return true;
- case "autoDiscoverClient": getOrCreateConfiguration((KinesisComponent) component).setAutoDiscoverClient((boolean) value); return true;
- case "configuration": ((KinesisComponent) component).setConfiguration((org.apache.camel.component.aws.kinesis.KinesisConfiguration) value); return true;
- case "proxyHost": getOrCreateConfiguration((KinesisComponent) component).setProxyHost((java.lang.String) value); return true;
- case "proxyPort": getOrCreateConfiguration((KinesisComponent) component).setProxyPort((java.lang.Integer) value); return true;
- case "proxyProtocol": getOrCreateConfiguration((KinesisComponent) component).setProxyProtocol((com.amazonaws.Protocol) value); return true;
- case "region": getOrCreateConfiguration((KinesisComponent) component).setRegion((java.lang.String) value); return true;
- case "bridgeErrorHandler": ((KinesisComponent) component).setBridgeErrorHandler((boolean) value); return true;
- case "iteratorType": getOrCreateConfiguration((KinesisComponent) component).setIteratorType((com.amazonaws.services.kinesis.model.ShardIteratorType) value); return true;
- case "maxResultsPerRequest": getOrCreateConfiguration((KinesisComponent) component).setMaxResultsPerRequest((int) value); return true;
- case "sequenceNumber": getOrCreateConfiguration((KinesisComponent) component).setSequenceNumber((java.lang.String) value); return true;
- case "shardClosed": getOrCreateConfiguration((KinesisComponent) component).setShardClosed((org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum) value); return true;
- case "shardId": getOrCreateConfiguration((KinesisComponent) component).setShardId((java.lang.String) value); return true;
- case "lazyStartProducer": ((KinesisComponent) component).setLazyStartProducer((boolean) value); return true;
- case "autowiredEnabled": ((KinesisComponent) component).setAutowiredEnabled((boolean) value); return true;
- case "accessKey": getOrCreateConfiguration((KinesisComponent) component).setAccessKey((java.lang.String) value); return true;
- case "secretKey": getOrCreateConfiguration((KinesisComponent) 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/AwsKinesisFirehoseComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsKinesisFirehoseComponentBuilderFactory.java
deleted file mode 100644
index 5c1c35b..0000000
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/AwsKinesisFirehoseComponentBuilderFactory.java
+++ /dev/null
@@ -1,287 +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.firehose.KinesisFirehoseComponent;
-
-/**
- * Consume data from AWS Kinesis Firehose streams.
- *
- * Generated by camel-package-maven-plugin - do not edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.ComponentDslMojo")
-public interface AwsKinesisFirehoseComponentBuilderFactory {
-
- /**
- * AWS Kinesis Firehose (camel-aws-kinesis)
- * Consume data from AWS Kinesis Firehose streams.
- *
- * Category: cloud,messaging
- * Since: 2.19
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * @return the dsl builder
- */
- @Deprecated
- static AwsKinesisFirehoseComponentBuilder awsKinesisFirehose() {
- return new AwsKinesisFirehoseComponentBuilderImpl();
- }
-
- /**
- * Builder for the AWS Kinesis Firehose component.
- */
- interface AwsKinesisFirehoseComponentBuilder
- extends
- ComponentBuilder<KinesisFirehoseComponent> {
- /**
- * Amazon Kinesis Firehose client to use for all requests for this
- * endpoint.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesisfirehose.AmazonKinesisFirehose</code> type.
- *
- * Group: producer
- *
- * @param amazonKinesisFirehoseClient the value to set
- * @return the dsl builder
- */
- default AwsKinesisFirehoseComponentBuilder amazonKinesisFirehoseClient(
- com.amazonaws.services.kinesisfirehose.AmazonKinesisFirehose amazonKinesisFirehoseClient) {
- doSetProperty("amazonKinesisFirehoseClient", amazonKinesisFirehoseClient);
- 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 AwsKinesisFirehoseComponentBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * The component configuration.
- *
- * The option is a:
- * <code>org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration</code> type.
- *
- * Group: producer
- *
- * @param configuration the value to set
- * @return the dsl builder
- */
- default AwsKinesisFirehoseComponentBuilder configuration(
- org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration configuration) {
- doSetProperty("configuration", configuration);
- 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 AwsKinesisFirehoseComponentBuilder lazyStartProducer(
- boolean lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * To define a proxy host when instantiating the Kinesis Firehose
- * client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default AwsKinesisFirehoseComponentBuilder proxyHost(
- java.lang.String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis Firehose
- * client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: producer
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default AwsKinesisFirehoseComponentBuilder proxyPort(
- java.lang.Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis Firehose
- * 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 AwsKinesisFirehoseComponentBuilder proxyProtocol(
- com.amazonaws.Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which Kinesis client needs to work. 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.String</code> type.
- *
- * Group: producer
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default AwsKinesisFirehoseComponentBuilder region(
- java.lang.String region) {
- doSetProperty("region", region);
- 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 AwsKinesisFirehoseComponentBuilder 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 AwsKinesisFirehoseComponentBuilder 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 AwsKinesisFirehoseComponentBuilder secretKey(
- java.lang.String secretKey) {
- doSetProperty("secretKey", secretKey);
- return this;
- }
- }
-
- class AwsKinesisFirehoseComponentBuilderImpl
- extends
- AbstractComponentBuilder<KinesisFirehoseComponent>
- implements
- AwsKinesisFirehoseComponentBuilder {
- @Override
- protected KinesisFirehoseComponent buildConcreteComponent() {
- return new KinesisFirehoseComponent();
- }
- private org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration getOrCreateConfiguration(
- org.apache.camel.component.aws.firehose.KinesisFirehoseComponent component) {
- if (component.getConfiguration() == null) {
- component.setConfiguration(new org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration());
- }
- return component.getConfiguration();
- }
- @Override
- protected boolean setPropertyOnComponent(
- Component component,
- String name,
- Object value) {
- switch (name) {
- case "amazonKinesisFirehoseClient": getOrCreateConfiguration((KinesisFirehoseComponent) component).setAmazonKinesisFirehoseClient((com.amazonaws.services.kinesisfirehose.AmazonKinesisFirehose) value); return true;
- case "autoDiscoverClient": getOrCreateConfiguration((KinesisFirehoseComponent) component).setAutoDiscoverClient((boolean) value); return true;
- case "configuration": ((KinesisFirehoseComponent) component).setConfiguration((org.apache.camel.component.aws.firehose.KinesisFirehoseConfiguration) value); return true;
- case "lazyStartProducer": ((KinesisFirehoseComponent) component).setLazyStartProducer((boolean) value); return true;
- case "proxyHost": getOrCreateConfiguration((KinesisFirehoseComponent) component).setProxyHost((java.lang.String) value); return true;
- case "proxyPort": getOrCreateConfiguration((KinesisFirehoseComponent) component).setProxyPort((java.lang.Integer) value); return true;
- case "proxyProtocol": getOrCreateConfiguration((KinesisFirehoseComponent) component).setProxyProtocol((com.amazonaws.Protocol) value); return true;
- case "region": getOrCreateConfiguration((KinesisFirehoseComponent) component).setRegion((java.lang.String) value); return true;
- case "autowiredEnabled": ((KinesisFirehoseComponent) component).setAutowiredEnabled((boolean) value); return true;
- case "accessKey": getOrCreateConfiguration((KinesisFirehoseComponent) component).setAccessKey((java.lang.String) value); return true;
- case "secretKey": getOrCreateConfiguration((KinesisFirehoseComponent) 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/dsl/KinesisEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
deleted file mode 100644
index 3178938..0000000
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisEndpointBuilderFactory.java
+++ /dev/null
@@ -1,1624 +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;
-
-/**
- * Consume and produce records from AWS Kinesis Streams.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface KinesisEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint consumers for the AWS Kinesis component.
- */
- public interface KinesisEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default AdvancedKinesisEndpointConsumerBuilder advanced() {
- return (AdvancedKinesisEndpointConsumerBuilder) this;
- }
- /**
- * Amazon Kinesis client to use for all requests for this endpoint.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesis.AmazonKinesis</code>
- * type.
- *
- * Group: common
- *
- * @param amazonKinesisClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder amazonKinesisClient(
- Object amazonKinesisClient) {
- doSetProperty("amazonKinesisClient", amazonKinesisClient);
- return this;
- }
- /**
- * Amazon Kinesis client to use for all requests for this endpoint.
- *
- * The option will be converted to a
- * <code>com.amazonaws.services.kinesis.AmazonKinesis</code>
- * type.
- *
- * Group: common
- *
- * @param amazonKinesisClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder amazonKinesisClient(
- String amazonKinesisClient) {
- doSetProperty("amazonKinesisClient", amazonKinesisClient);
- 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 KinesisEndpointConsumerBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component will
- * look for a client instance in the registry automatically otherwise it
- * will skip that checking.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder autoDiscoverClient(
- String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * To define a proxy host when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder proxyHost(String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: common
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder proxyPort(Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis client.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: common
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder proxyPort(String proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis client.
- *
- * The option is a: <code>com.amazonaws.Protocol</code>
- * type.
- *
- * Default: HTTPS
- * Group: common
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder proxyProtocol(
- Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis client.
- *
- * The option will be converted to a
- * <code>com.amazonaws.Protocol</code> type.
- *
- * Default: HTTPS
- * Group: common
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder proxyProtocol(
- String proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which Kinesis client needs to work. 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.String</code> type.
- *
- * Group: common
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder region(String region) {
- doSetProperty("region", region);
- 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * Defines where in the Kinesis stream to start getting records.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesis.model.ShardIteratorType</code> type.
- *
- * Default: TRIM_HORIZON
- * Group: consumer
- *
- * @param iteratorType the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder iteratorType(
- ShardIteratorType iteratorType) {
- doSetProperty("iteratorType", iteratorType);
- return this;
- }
- /**
- * Defines where in the Kinesis stream to start getting records.
- *
- * The option will be converted to a
- * <code>com.amazonaws.services.kinesis.model.ShardIteratorType</code> type.
- *
- * Default: TRIM_HORIZON
- * Group: consumer
- *
- * @param iteratorType the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder 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.
- *
- * Default: 1
- * Group: consumer
- *
- * @param maxResultsPerRequest the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder 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.
- *
- * Default: 1
- * Group: consumer
- *
- * @param maxResultsPerRequest the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder maxResultsPerRequest(
- String maxResultsPerRequest) {
- doSetProperty("maxResultsPerRequest", maxResultsPerRequest);
- 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder sendEmptyMessageWhenIdle(
- String sendEmptyMessageWhenIdle) {
- doSetProperty("sendEmptyMessageWhenIdle", sendEmptyMessageWhenIdle);
- return this;
- }
- /**
- * The sequence number to start polling from. Required if iteratorType
- * is set to AFTER_SEQUENCE_NUMBER or AT_SEQUENCE_NUMBER.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- *
- * @param sequenceNumber the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder sequenceNumber(
- String sequenceNumber) {
- doSetProperty("sequenceNumber", sequenceNumber);
- return this;
- }
- /**
- * Define what will be the behavior in case of shard closed. Possible
- * value are ignore, silent and fail. In case of ignore a message will
- * be logged and the consumer will restart from the beginning,in case of
- * silent there will be no logging and the consumer will start from the
- * beginning,in case of fail a ReachedClosedStateException will be
- * raised.
- *
- * The option is a:
- * <code>org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum</code> type.
- *
- * Default: ignore
- * Group: consumer
- *
- * @param shardClosed the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder shardClosed(
- KinesisShardClosedStrategyEnum shardClosed) {
- doSetProperty("shardClosed", shardClosed);
- return this;
- }
- /**
- * Define what will be the behavior in case of shard closed. Possible
- * value are ignore, silent and fail. In case of ignore a message will
- * be logged and the consumer will restart from the beginning,in case of
- * silent there will be no logging and the consumer will start from the
- * beginning,in case of fail a ReachedClosedStateException will be
- * raised.
- *
- * The option will be converted to a
- * <code>org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum</code> type.
- *
- * Default: ignore
- * Group: consumer
- *
- * @param shardClosed the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder shardClosed(String shardClosed) {
- doSetProperty("shardClosed", shardClosed);
- return this;
- }
- /**
- * Defines which shardId in the Kinesis stream to get records from.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: consumer
- *
- * @param shardId the value to set
- * @return the dsl builder
- */
- default KinesisEndpointConsumerBuilder shardId(String shardId) {
- doSetProperty("shardId", shardId);
- 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder 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 KinesisEndpointConsumerBuilder secretKey(String secretKey) {
- doSetProperty("secretKey", secretKey);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint consumers for the AWS Kinesis component.
- */
- public interface AdvancedKinesisEndpointConsumerBuilder
- extends
- EndpointConsumerBuilder {
- default KinesisEndpointConsumerBuilder basic() {
- return (KinesisEndpointConsumerBuilder) 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 AdvancedKinesisEndpointConsumerBuilder 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 AdvancedKinesisEndpointConsumerBuilder 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 AdvancedKinesisEndpointConsumerBuilder 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 AdvancedKinesisEndpointConsumerBuilder 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 AdvancedKinesisEndpointConsumerBuilder 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 AdvancedKinesisEndpointConsumerBuilder pollStrategy(
- String pollStrategy) {
- doSetProperty("pollStrategy", pollStrategy);
- return this;
- }
- }
-
- /**
- * Builder for endpoint producers for the AWS Kinesis component.
- */
- public interface KinesisEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default AdvancedKinesisEndpointProducerBuilder advanced() {
- return (AdvancedKinesisEndpointProducerBuilder) this;
- }
- /**
- * Amazon Kinesis client to use for all requests for this endpoint.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesis.AmazonKinesis</code>
- * type.
- *
- * Group: common
- *
- * @param amazonKinesisClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder amazonKinesisClient(
- Object amazonKinesisClient) {
- doSetProperty("amazonKinesisClient", amazonKinesisClient);
- return this;
- }
- /**
- * Amazon Kinesis client to use for all requests for this endpoint.
- *
- * The option will be converted to a
- * <code>com.amazonaws.services.kinesis.AmazonKinesis</code>
- * type.
- *
- * Group: common
- *
- * @param amazonKinesisClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder amazonKinesisClient(
- String amazonKinesisClient) {
- doSetProperty("amazonKinesisClient", amazonKinesisClient);
- 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 KinesisEndpointProducerBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component will
- * look for a client instance in the registry automatically otherwise it
- * will skip that checking.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder autoDiscoverClient(
- String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * To define a proxy host when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder proxyHost(String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: common
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder proxyPort(Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis client.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: common
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder proxyPort(String proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis client.
- *
- * The option is a: <code>com.amazonaws.Protocol</code>
- * type.
- *
- * Default: HTTPS
- * Group: common
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder proxyProtocol(
- Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis client.
- *
- * The option will be converted to a
- * <code>com.amazonaws.Protocol</code> type.
- *
- * Default: HTTPS
- * Group: common
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder proxyProtocol(
- String proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which Kinesis client needs to work. 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.String</code> type.
- *
- * Group: common
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default KinesisEndpointProducerBuilder region(String region) {
- doSetProperty("region", region);
- 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 KinesisEndpointProducerBuilder 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 KinesisEndpointProducerBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- 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 KinesisEndpointProducerBuilder 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 KinesisEndpointProducerBuilder secretKey(String secretKey) {
- doSetProperty("secretKey", secretKey);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint producers for the AWS Kinesis component.
- */
- public interface AdvancedKinesisEndpointProducerBuilder
- extends
- EndpointProducerBuilder {
- default KinesisEndpointProducerBuilder basic() {
- return (KinesisEndpointProducerBuilder) this;
- }
- }
-
- /**
- * Builder for endpoint for the AWS Kinesis component.
- */
- public interface KinesisEndpointBuilder
- extends
- KinesisEndpointConsumerBuilder,
- KinesisEndpointProducerBuilder {
- default AdvancedKinesisEndpointBuilder advanced() {
- return (AdvancedKinesisEndpointBuilder) this;
- }
- /**
- * Amazon Kinesis client to use for all requests for this endpoint.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesis.AmazonKinesis</code>
- * type.
- *
- * Group: common
- *
- * @param amazonKinesisClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder amazonKinesisClient(
- Object amazonKinesisClient) {
- doSetProperty("amazonKinesisClient", amazonKinesisClient);
- return this;
- }
- /**
- * Amazon Kinesis client to use for all requests for this endpoint.
- *
- * The option will be converted to a
- * <code>com.amazonaws.services.kinesis.AmazonKinesis</code>
- * type.
- *
- * Group: common
- *
- * @param amazonKinesisClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder amazonKinesisClient(
- String amazonKinesisClient) {
- doSetProperty("amazonKinesisClient", amazonKinesisClient);
- 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 KinesisEndpointBuilder autoDiscoverClient(
- boolean autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Setting the autoDiscoverClient mechanism, if true, the component will
- * look for a client instance in the registry automatically otherwise it
- * will skip that checking.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: true
- * Group: common
- *
- * @param autoDiscoverClient the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder autoDiscoverClient(
- String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * To define a proxy host when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder proxyHost(String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: common
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder proxyPort(Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis client.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Group: common
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder proxyPort(String proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis client.
- *
- * The option is a: <code>com.amazonaws.Protocol</code>
- * type.
- *
- * Default: HTTPS
- * Group: common
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder proxyProtocol(Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis client.
- *
- * The option will be converted to a
- * <code>com.amazonaws.Protocol</code> type.
- *
- * Default: HTTPS
- * Group: common
- *
- * @param proxyProtocol the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder proxyProtocol(String proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which Kinesis client needs to work. 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.String</code> type.
- *
- * Group: common
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default KinesisEndpointBuilder region(String region) {
- doSetProperty("region", region);
- 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 KinesisEndpointBuilder 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 KinesisEndpointBuilder secretKey(String secretKey) {
- doSetProperty("secretKey", secretKey);
- return this;
- }
- }
-
- /**
- * Advanced builder for endpoint for the AWS Kinesis component.
- */
- public interface AdvancedKinesisEndpointBuilder
- extends
- AdvancedKinesisEndpointConsumerBuilder,
- AdvancedKinesisEndpointProducerBuilder {
- default KinesisEndpointBuilder basic() {
- return (KinesisEndpointBuilder) this;
- }
- }
-
- /**
- * Proxy enum for <code>com.amazonaws.Protocol</code> enum.
- */
- enum Protocol {
- HTTP,
- HTTPS;
- }
-
- /**
- * Proxy enum for
- * <code>com.amazonaws.services.kinesis.model.ShardIteratorType</code> enum.
- */
- enum ShardIteratorType {
- AT_SEQUENCE_NUMBER,
- AFTER_SEQUENCE_NUMBER,
- TRIM_HORIZON,
- LATEST,
- AT_TIMESTAMP;
- }
-
- /**
- * Proxy enum for
- * <code>org.apache.camel.component.aws.kinesis.KinesisShardClosedStrategyEnum</code> enum.
- */
- enum KinesisShardClosedStrategyEnum {
- ignore,
- fail,
- silent;
- }
-
- public interface KinesisBuilders {
- /**
- * AWS Kinesis (camel-aws-kinesis)
- * Consume and produce records from AWS Kinesis Streams.
- *
- * Category: cloud,messaging
- * Since: 2.17
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * Syntax: <code>aws-kinesis:streamName</code>
- *
- * Path parameter: streamName (required)
- * Name of the stream
- *
- * @param path streamName
- * @return the dsl builder
- */
- @Deprecated
- default KinesisEndpointBuilder awsKinesis(String path) {
- return KinesisEndpointBuilderFactory.endpointBuilder("aws-kinesis", path);
- }
- /**
- * AWS Kinesis (camel-aws-kinesis)
- * Consume and produce records from AWS Kinesis Streams.
- *
- * Category: cloud,messaging
- * Since: 2.17
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * Syntax: <code>aws-kinesis:streamName</code>
- *
- * Path parameter: streamName (required)
- * Name of the stream
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path streamName
- * @return the dsl builder
- */
- @Deprecated
- default KinesisEndpointBuilder awsKinesis(
- String componentName,
- String path) {
- return KinesisEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
- @Deprecated
- static KinesisEndpointBuilder endpointBuilder(
- String componentName,
- String path) {
- class KinesisEndpointBuilderImpl extends AbstractEndpointBuilder implements KinesisEndpointBuilder, AdvancedKinesisEndpointBuilder {
- public KinesisEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new KinesisEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisFirehoseEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisFirehoseEndpointBuilderFactory.java
deleted file mode 100644
index d9bcae4..0000000
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/KinesisFirehoseEndpointBuilderFactory.java
+++ /dev/null
@@ -1,353 +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;
-
-/**
- * Consume data from AWS Kinesis Firehose streams.
- *
- * Generated by camel build tools - do NOT edit this file!
- */
-@Generated("org.apache.camel.maven.packaging.EndpointDslMojo")
-public interface KinesisFirehoseEndpointBuilderFactory {
-
-
- /**
- * Builder for endpoint for the AWS Kinesis Firehose component.
- */
- public interface KinesisFirehoseEndpointBuilder
- extends
- EndpointProducerBuilder {
- /**
- * Amazon Kinesis Firehose client to use for all requests for this
- * endpoint.
- *
- * The option is a:
- * <code>com.amazonaws.services.kinesisfirehose.AmazonKinesisFirehose</code> type.
- *
- * Group: producer
- *
- * @param amazonKinesisFirehoseClient the value to set
- * @return the dsl builder
- */
- default KinesisFirehoseEndpointBuilder amazonKinesisFirehoseClient(
- Object amazonKinesisFirehoseClient) {
- doSetProperty("amazonKinesisFirehoseClient", amazonKinesisFirehoseClient);
- return this;
- }
- /**
- * Amazon Kinesis Firehose client to use for all requests for this
- * endpoint.
- *
- * The option will be converted to a
- * <code>com.amazonaws.services.kinesisfirehose.AmazonKinesisFirehose</code> type.
- *
- * Group: producer
- *
- * @param amazonKinesisFirehoseClient the value to set
- * @return the dsl builder
- */
- default KinesisFirehoseEndpointBuilder amazonKinesisFirehoseClient(
- String amazonKinesisFirehoseClient) {
- doSetProperty("amazonKinesisFirehoseClient", amazonKinesisFirehoseClient);
- 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 KinesisFirehoseEndpointBuilder 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 KinesisFirehoseEndpointBuilder autoDiscoverClient(
- String autoDiscoverClient) {
- doSetProperty("autoDiscoverClient", autoDiscoverClient);
- return this;
- }
- /**
- * Whether the producer should be started lazy (on the first message).
- * By starting lazy you can use this to allow CamelContext and routes to
- * startup in situations where a producer may otherwise fail during
- * 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 KinesisFirehoseEndpointBuilder 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 KinesisFirehoseEndpointBuilder lazyStartProducer(
- String lazyStartProducer) {
- doSetProperty("lazyStartProducer", lazyStartProducer);
- return this;
- }
- /**
- * To define a proxy host when instantiating the Kinesis Firehose
- * client.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: producer
- *
- * @param proxyHost the value to set
- * @return the dsl builder
- */
- default KinesisFirehoseEndpointBuilder proxyHost(String proxyHost) {
- doSetProperty("proxyHost", proxyHost);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis Firehose
- * client.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Group: producer
- *
- * @param proxyPort the value to set
- * @return the dsl builder
- */
- default KinesisFirehoseEndpointBuilder proxyPort(Integer proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy port when instantiating the Kinesis Firehose
- * client.
- *
- * 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 KinesisFirehoseEndpointBuilder proxyPort(String proxyPort) {
- doSetProperty("proxyPort", proxyPort);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis Firehose
- * 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 KinesisFirehoseEndpointBuilder proxyProtocol(
- Protocol proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * To define a proxy protocol when instantiating the Kinesis Firehose
- * 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 KinesisFirehoseEndpointBuilder proxyProtocol(
- String proxyProtocol) {
- doSetProperty("proxyProtocol", proxyProtocol);
- return this;
- }
- /**
- * The region in which Kinesis client needs to work. 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.String</code> type.
- *
- * Group: producer
- *
- * @param region the value to set
- * @return the dsl builder
- */
- default KinesisFirehoseEndpointBuilder region(String region) {
- doSetProperty("region", region);
- 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 KinesisFirehoseEndpointBuilder 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 KinesisFirehoseEndpointBuilder secretKey(String secretKey) {
- doSetProperty("secretKey", secretKey);
- return this;
- }
- }
-
- /**
- * Proxy enum for <code>com.amazonaws.Protocol</code> enum.
- */
- enum Protocol {
- HTTP,
- HTTPS;
- }
-
- public interface KinesisFirehoseBuilders {
- /**
- * AWS Kinesis Firehose (camel-aws-kinesis)
- * Consume data from AWS Kinesis Firehose streams.
- *
- * Category: cloud,messaging
- * Since: 2.19
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * Syntax: <code>aws-kinesis-firehose:streamName</code>
- *
- * Path parameter: streamName (required)
- * Name of the stream
- *
- * @param path streamName
- * @return the dsl builder
- */
- @Deprecated
- default KinesisFirehoseEndpointBuilder awsKinesisFirehose(String path) {
- return KinesisFirehoseEndpointBuilderFactory.endpointBuilder("aws-kinesis-firehose", path);
- }
- /**
- * AWS Kinesis Firehose (camel-aws-kinesis)
- * Consume data from AWS Kinesis Firehose streams.
- *
- * Category: cloud,messaging
- * Since: 2.19
- * Maven coordinates: org.apache.camel:camel-aws-kinesis
- *
- * Syntax: <code>aws-kinesis-firehose:streamName</code>
- *
- * Path parameter: streamName (required)
- * Name of the stream
- *
- * @param componentName to use a custom component name for the endpoint
- * instead of the default name
- * @param path streamName
- * @return the dsl builder
- */
- @Deprecated
- default KinesisFirehoseEndpointBuilder awsKinesisFirehose(
- String componentName,
- String path) {
- return KinesisFirehoseEndpointBuilderFactory.endpointBuilder(componentName, path);
- }
- }
- @Deprecated
- static KinesisFirehoseEndpointBuilder endpointBuilder(
- String componentName,
- String path) {
- class KinesisFirehoseEndpointBuilderImpl extends AbstractEndpointBuilder implements KinesisFirehoseEndpointBuilder {
- public KinesisFirehoseEndpointBuilderImpl(String path) {
- super(componentName, path);
- }
- }
- return new KinesisFirehoseEndpointBuilderImpl(path);
- }
-}
\ No newline at end of file