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