@Configuration(proxyBeanMethods=false) @ConditionalOnMissingBean(value=org.springframework.cloud.stream.binder.Binder.class) @EnableConfigurationProperties(value={KinesisBinderConfigurationProperties.class,KinesisExtendedBindingProperties.class}) @Import(value={org.springframework.cloud.aws.autoconfigure.context.ContextCredentialsAutoConfiguration.class,org.springframework.cloud.aws.autoconfigure.context.ContextRegionProviderAutoConfiguration.class}) public class KinesisBinderConfiguration extends Object
Modifier and Type | Class and Description |
---|---|
protected static class |
KinesisBinderConfiguration.KinesisBinderHealthIndicatorConfiguration |
Constructor and Description |
---|
KinesisBinderConfiguration(KinesisBinderConfigurationProperties configurationProperties,
com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider,
org.springframework.cloud.aws.core.region.RegionProvider regionProvider,
List<org.springframework.cloud.stream.binding.Bindable> bindables) |
Modifier and Type | Method and Description |
---|---|
com.amazonaws.services.kinesis.AmazonKinesisAsync |
amazonKinesis() |
com.amazonaws.services.cloudwatch.AmazonCloudWatchAsync |
cloudWatch() |
com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync |
dynamoDB() |
org.springframework.integration.support.locks.LockRegistry |
dynamoDBLockRegistry(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB) |
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams |
dynamoDBStreams() |
org.springframework.integration.metadata.ConcurrentMetadataStore |
kinesisCheckpointStore(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB) |
KinesisMessageChannelBinder |
kinesisMessageChannelBinder(KinesisStreamProvisioner provisioningProvider,
com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis,
KinesisExtendedBindingProperties kinesisExtendedBindingProperties,
org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore,
org.springframework.integration.support.locks.LockRegistry lockRegistry,
com.amazonaws.services.dynamodbv2.AmazonDynamoDB dynamoDBClient,
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams dynamoDBStreams,
com.amazonaws.services.cloudwatch.AmazonCloudWatch cloudWatchClient,
com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration kinesisProducerConfiguration,
org.springframework.cloud.stream.config.ProducerMessageHandlerCustomizer<? extends org.springframework.integration.aws.outbound.AbstractAwsMessageHandler<Void>> producerMessageHandlerCustomizer,
org.springframework.cloud.stream.config.ConsumerEndpointCustomizer<? extends org.springframework.integration.endpoint.MessageProducerSupport> consumerEndpointCustomizer,
List<com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration> kinesisClientLibConfigurations) |
com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration |
kinesisProducerConfiguration() |
KinesisStreamProvisioner |
provisioningProvider(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis) |
public KinesisBinderConfiguration(KinesisBinderConfigurationProperties configurationProperties, com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider, org.springframework.cloud.aws.core.region.RegionProvider regionProvider, List<org.springframework.cloud.stream.binding.Bindable> bindables)
@Bean @ConditionalOnMissingBean public com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis()
@Bean public KinesisStreamProvisioner provisioningProvider(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis)
@Bean @ConditionalOnMissingBean public com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB()
@Bean @ConditionalOnMissingBean @ConditionalOnBean(value=com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync.class) @ConditionalOnProperty(name="spring.cloud.stream.kinesis.binder.kpl-kcl-enabled", havingValue="false", matchIfMissing=true) public org.springframework.integration.support.locks.LockRegistry dynamoDBLockRegistry(@Autowired(required=false) com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)
@Bean @ConditionalOnMissingBean @ConditionalOnBean(value=com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync.class) @ConditionalOnProperty(name="spring.cloud.stream.kinesis.binder.kpl-kcl-enabled", havingValue="false", matchIfMissing=true) public org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore(@Autowired(required=false) com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)
@Bean @ConditionalOnMissingBean public com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams dynamoDBStreams()
@Bean @ConditionalOnMissingBean @ConditionalOnProperty(name="spring.cloud.stream.kinesis.binder.kpl-kcl-enabled") public com.amazonaws.services.cloudwatch.AmazonCloudWatchAsync cloudWatch()
@Bean @ConditionalOnMissingBean @ConditionalOnProperty(name="spring.cloud.stream.kinesis.binder.kpl-kcl-enabled") public com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration kinesisProducerConfiguration()
@Bean public KinesisMessageChannelBinder kinesisMessageChannelBinder(KinesisStreamProvisioner provisioningProvider, com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis, KinesisExtendedBindingProperties kinesisExtendedBindingProperties, @Autowired(required=false) org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore, @Autowired(required=false) org.springframework.integration.support.locks.LockRegistry lockRegistry, @Autowired(required=false) com.amazonaws.services.dynamodbv2.AmazonDynamoDB dynamoDBClient, @Autowired(required=false) com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams dynamoDBStreams, @Autowired(required=false) com.amazonaws.services.cloudwatch.AmazonCloudWatch cloudWatchClient, @Autowired(required=false) com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration kinesisProducerConfiguration, @Autowired(required=false) org.springframework.cloud.stream.config.ProducerMessageHandlerCustomizer<? extends org.springframework.integration.aws.outbound.AbstractAwsMessageHandler<Void>> producerMessageHandlerCustomizer, @Autowired(required=false) org.springframework.cloud.stream.config.ConsumerEndpointCustomizer<? extends org.springframework.integration.endpoint.MessageProducerSupport> consumerEndpointCustomizer, @Autowired List<com.amazonaws.services.kinesis.clientlibrary.lib.worker.KinesisClientLibConfiguration> kinesisClientLibConfigurations)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.