@Configuration @ConditionalOnMissingBean(value=org.springframework.cloud.stream.binder.Binder.class) @EnableConfigurationProperties(value={KinesisBinderConfigurationProperties.class,KinesisExtendedBindingProperties.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) |
KinesisStreamProvisioner |
provisioningProvider(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis) |
@Bean 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)
Copyright © 2017 Pivotal Software, Inc.. All rights reserved.