Interface KinesisEndpointBuilderFactory.KinesisEndpointBuilder
-
- All Superinterfaces:
org.apache.camel.builder.EndpointConsumerBuilder
,org.apache.camel.EndpointConsumerResolver
,org.apache.camel.builder.EndpointProducerBuilder
,org.apache.camel.EndpointProducerResolver
,KinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
,KinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
- Enclosing interface:
- KinesisEndpointBuilderFactory
public static interface KinesisEndpointBuilderFactory.KinesisEndpointBuilder extends KinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder, KinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
Builder for endpoint for the AWS Kinesis component.
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
accessKey(String accessKey)
Amazon AWS Access Key.default KinesisEndpointBuilderFactory.AdvancedKinesisEndpointBuilder
advanced()
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
amazonKinesisClient(Object amazonKinesisClient)
Amazon Kinesis client to use for all requests for this endpoint.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
amazonKinesisClient(String amazonKinesisClient)
Amazon Kinesis client to use for all requests for this endpoint.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
autoDiscoverClient(boolean autoDiscoverClient)
Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
autoDiscoverClient(String autoDiscoverClient)
Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
proxyHost(String proxyHost)
To define a proxy host when instantiating the Kinesis client.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
proxyPort(Integer proxyPort)
To define a proxy port when instantiating the Kinesis client.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
proxyPort(String proxyPort)
To define a proxy port when instantiating the Kinesis client.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
proxyProtocol(String proxyProtocol)
To define a proxy protocol when instantiating the Kinesis client.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
proxyProtocol(KinesisEndpointBuilderFactory.Protocol proxyProtocol)
To define a proxy protocol when instantiating the Kinesis client.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
region(String region)
The region in which Kinesis client needs to work.default KinesisEndpointBuilderFactory.KinesisEndpointBuilder
secretKey(String secretKey)
Amazon AWS Secret Key.-
Methods inherited from interface org.apache.camel.builder.EndpointConsumerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, getUri
-
Methods inherited from interface org.apache.camel.builder.EndpointProducerBuilder
doSetMultiValueProperties, doSetMultiValueProperty, doSetProperty, expr, expr, getUri
-
Methods inherited from interface org.apache.camel.builder.endpoint.dsl.KinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
backoffErrorThreshold, backoffErrorThreshold, backoffIdleThreshold, backoffIdleThreshold, backoffMultiplier, backoffMultiplier, bridgeErrorHandler, bridgeErrorHandler, delay, delay, greedy, greedy, initialDelay, initialDelay, iteratorType, iteratorType, maxResultsPerRequest, maxResultsPerRequest, repeatCount, repeatCount, runLoggingLevel, runLoggingLevel, scheduledExecutorService, scheduledExecutorService, scheduler, scheduler, schedulerProperties, schedulerProperties, sendEmptyMessageWhenIdle, sendEmptyMessageWhenIdle, sequenceNumber, shardClosed, shardClosed, shardId, startScheduler, startScheduler, timeUnit, timeUnit, useFixedDelay, useFixedDelay
-
Methods inherited from interface org.apache.camel.builder.endpoint.dsl.KinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
lazyStartProducer, lazyStartProducer
-
-
-
-
Method Detail
-
advanced
default KinesisEndpointBuilderFactory.AdvancedKinesisEndpointBuilder advanced()
- Specified by:
advanced
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
advanced
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
amazonKinesisClient
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder amazonKinesisClient(Object amazonKinesisClient)
Amazon Kinesis client to use for all requests for this endpoint. The option is a:com.amazonaws.services.kinesis.AmazonKinesis
type. Group: common- Specified by:
amazonKinesisClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
amazonKinesisClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
amazonKinesisClient
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder amazonKinesisClient(String amazonKinesisClient)
Amazon Kinesis client to use for all requests for this endpoint. The option will be converted to acom.amazonaws.services.kinesis.AmazonKinesis
type. Group: common- Specified by:
amazonKinesisClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
amazonKinesisClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
autoDiscoverClient
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder autoDiscoverClient(boolean autoDiscoverClient)
Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. The option is a:boolean
type. Default: true Group: common- Specified by:
autoDiscoverClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
autoDiscoverClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
autoDiscoverClient
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder autoDiscoverClient(String autoDiscoverClient)
Setting the autoDiscoverClient mechanism, if true, the component will look for a client instance in the registry automatically otherwise it will skip that checking. The option will be converted to aboolean
type. Default: true Group: common- Specified by:
autoDiscoverClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
autoDiscoverClient
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
proxyHost
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder proxyHost(String proxyHost)
To define a proxy host when instantiating the Kinesis client. The option is a:java.lang.String
type. Group: common- Specified by:
proxyHost
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
proxyHost
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
proxyPort
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder proxyPort(Integer proxyPort)
To define a proxy port when instantiating the Kinesis client. The option is a:java.lang.Integer
type. Group: common- Specified by:
proxyPort
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
proxyPort
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
proxyPort
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder proxyPort(String proxyPort)
To define a proxy port when instantiating the Kinesis client. The option will be converted to ajava.lang.Integer
type. Group: common- Specified by:
proxyPort
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
proxyPort
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
proxyProtocol
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder proxyProtocol(KinesisEndpointBuilderFactory.Protocol proxyProtocol)
To define a proxy protocol when instantiating the Kinesis client. The option is a:com.amazonaws.Protocol
type. Default: HTTPS Group: common- Specified by:
proxyProtocol
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
proxyProtocol
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
proxyProtocol
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder proxyProtocol(String proxyProtocol)
To define a proxy protocol when instantiating the Kinesis client. The option will be converted to acom.amazonaws.Protocol
type. Default: HTTPS Group: common- Specified by:
proxyProtocol
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
proxyProtocol
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
region
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder region(String region)
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:java.lang.String
type. Group: common- Specified by:
region
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
region
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
accessKey
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder accessKey(String accessKey)
Amazon AWS Access Key. The option is a:java.lang.String
type. Group: security- Specified by:
accessKey
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
accessKey
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
secretKey
default KinesisEndpointBuilderFactory.KinesisEndpointBuilder secretKey(String secretKey)
Amazon AWS Secret Key. The option is a:java.lang.String
type. Group: security- Specified by:
secretKey
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointConsumerBuilder
- Specified by:
secretKey
in interfaceKinesisEndpointBuilderFactory.KinesisEndpointProducerBuilder
-
-