Package | Description |
---|---|
org.springframework.cloud.stream.binder.kinesis | |
org.springframework.cloud.stream.binder.kinesis.config |
Constructor and Description |
---|
KinesisMessageChannelBinder(KinesisBinderConfigurationProperties configurationProperties,
KinesisStreamProvisioner provisioningProvider,
com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis,
com.amazonaws.auth.AWSCredentialsProvider awsCredentialsProvider,
com.amazonaws.services.dynamodbv2.AmazonDynamoDB dynamoDBClient,
com.amazonaws.services.dynamodbv2.AmazonDynamoDBStreams dynamoDBStreams,
com.amazonaws.services.cloudwatch.AmazonCloudWatch cloudWatchClient) |
Modifier and Type | Method and Description |
---|---|
KinesisStreamProvisioner |
KinesisBinderConfiguration.provisioningProvider(com.amazonaws.services.kinesis.AmazonKinesisAsync amazonKinesis) |
Modifier and Type | Method and Description |
---|---|
KinesisMessageChannelBinder |
KinesisBinderConfiguration.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) |
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.