@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
Constructor and Description |
---|
KinesisBinderConfiguration() |
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) |
@Bean @ConditionalOnMissingBean public com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis(com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider, org.springframework.cloud.aws.core.region.RegionProvider regionProvider)
@Bean public KinesisStreamProvisioner provisioningProvider(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis)
@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)
@Bean @ConditionalOnMissingBean public com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB(com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider, org.springframework.cloud.aws.core.region.RegionProvider regionProvider)
@Bean @ConditionalOnMissingBean public org.springframework.integration.support.locks.LockRegistry dynamoDBLockRegistry(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)
@Bean @ConditionalOnMissingBean public org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore(com.amazonaws.services.dynamodbv2.AmazonDynamoDBAsync dynamoDB)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.