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

Class KinesisBinderConfiguration

java.lang.Object

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

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

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

Author:

Peter Oates, Artem Bilan

Constructor Summary

Constructors

Constructor and Description
KinesisBinderConfiguration()

Method Summary

Modifier and Type	Method and Description
com.amazonaws.services.kinesis.AmazonKinesisAsync	amazonKinesis(com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider, org.springframework.cloud.aws.core.region.RegionProvider regionProvider)
com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync	dynamoDB(com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider, org.springframework.cloud.aws.core.region.RegionProvider regionProvider)
org.springframework.integration.support.locks.LockRegistry	dynamoDBLockRegistry(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)
org.springframework.integration.metadata.ConcurrentMetadataStore	kinesisCheckpointStore(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)
KinesisMessageChannelBinder	kinesisMessageChannelBinder(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis, KinesisStreamProvisioner provisioningProvider, org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore, org.springframework.integration.support.locks.LockRegistry lockRegistry, KinesisExtendedBindingProperties kinesisExtendedBindingProperties)
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()

Method Detail

amazonKinesis

@Bean
 @ConditionalOnMissingBean
public com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis(com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider,
                                                                                                        org.springframework.cloud.aws.core.region.RegionProvider regionProvider)

provisioningProvider

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

kinesisMessageChannelBinder

@Bean
public KinesisMessageChannelBinder kinesisMessageChannelBinder(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis,
                                                                     KinesisStreamProvisioner provisioningProvider,
                                                                     org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore,
                                                                     org.springframework.integration.support.locks.LockRegistry lockRegistry,
                                                                     KinesisExtendedBindingProperties kinesisExtendedBindingProperties)

dynamoDB

@Bean
 @ConditionalOnMissingBean
public com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB(com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider,
                                                                                                       org.springframework.cloud.aws.core.region.RegionProvider regionProvider)

dynamoDBLockRegistry

@Bean
 @ConditionalOnMissingBean
public org.springframework.integration.support.locks.LockRegistry dynamoDBLockRegistry(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)

kinesisCheckpointStore

@Bean
 @ConditionalOnMissingBean
public org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)