org.springframework.cloud.stream.binder.kinesis.config

Class KinesisBinderConfiguration

java.lang.Object

org.springframework.cloud.stream.binder.kinesis.config.KinesisBinderConfiguration

@Configuration(proxyBeanMethods=false)
 @ConditionalOnMissingBean(value=org.springframework.cloud.stream.binder.Binder.class)
 @EnableConfigurationProperties(value={KinesisBinderConfigurationProperties.class,KinesisExtendedBindingProperties.class})
 @Import(value={io.awspring.cloud.autoconfigure.context.ContextCredentialsAutoConfiguration.class,io.awspring.cloud.autoconfigure.context.ContextRegionProviderAutoConfiguration.class})
public class KinesisBinderConfiguration
extends Object

The auto-configuration for AWS components and Spring Cloud Stream Kinesis Binder.

Author:

Peter Oates, Artem Bilan, Arnaud Lecollaire, Asiel Caballero

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	KinesisBinderConfiguration.KinesisBinderHealthIndicatorConfiguration

Constructor Summary

Constructors

Constructor and Description
KinesisBinderConfiguration(KinesisBinderConfigurationProperties configurationProperties, com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider, io.awspring.cloud.core.region.RegionProvider regionProvider, List<org.springframework.cloud.stream.binding.Bindable> bindables)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KinesisBinderConfiguration

public KinesisBinderConfiguration(KinesisBinderConfigurationProperties configurationProperties,
                                  com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider,
                                  io.awspring.cloud.core.region.RegionProvider regionProvider,
                                  List<org.springframework.cloud.stream.binding.Bindable> bindables)

Method Detail

amazonKinesis

@Bean
 @ConditionalOnMissingBean
public com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis()

provisioningProvider

@Bean
public KinesisStreamProvisioner provisioningProvider(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis)

dynamoDB

@Bean
 @ConditionalOnMissingBean
public com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB()

dynamoDBLockRegistry

@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)

kinesisCheckpointStore

@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)

dynamoDBStreams

@Bean
 @ConditionalOnMissingBean
public com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams dynamoDBStreams()

cloudWatch

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnProperty(name="spring.cloud.stream.kinesis.binder.kpl-kcl-enabled")
public com.amazonaws.services.cloudwatch.AmazonCloudWatchAsync cloudWatch()

kinesisProducerConfiguration

@Bean
 @ConditionalOnMissingBean
 @ConditionalOnProperty(name="spring.cloud.stream.kinesis.binder.kpl-kcl-enabled")
public com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration kinesisProducerConfiguration()

kinesisMessageChannelBinder

@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)