Uses of Class
io.awspring.cloud.kinesis.stream.binder.provisioning.KinesisStreamProvisioner
Packages that use KinesisStreamProvisioner
Package
Description
-
Uses of KinesisStreamProvisioner in io.awspring.cloud.kinesis.stream.binder
Subclasses with type arguments of type KinesisStreamProvisioner in io.awspring.cloud.kinesis.stream.binderModifier and TypeClassDescriptionclassThe Spring Cloud Stream Binder implementation for AWS Kinesis.Constructors in io.awspring.cloud.kinesis.stream.binder with parameters of type KinesisStreamProvisionerModifierConstructorDescriptionKinesisMessageChannelBinder(KinesisBinderConfigurationProperties configurationProperties, KinesisStreamProvisioner provisioningProvider, software.amazon.awssdk.services.kinesis.KinesisAsyncClient amazonKinesis, @Nullable software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient dynamoDBClient, @Nullable software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient dynamoDBStreams, @Nullable software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient cloudWatchClient) -
Uses of KinesisStreamProvisioner in io.awspring.cloud.kinesis.stream.binder.config
Methods in io.awspring.cloud.kinesis.stream.binder.config that return KinesisStreamProvisionerModifier and TypeMethodDescriptionKinesisBinderConfiguration.provisioningProvider(software.amazon.awssdk.services.kinesis.KinesisAsyncClient amazonKinesis) Methods in io.awspring.cloud.kinesis.stream.binder.config with parameters of type KinesisStreamProvisionerModifier and TypeMethodDescriptionKinesisBinderConfiguration.kinesisMessageChannelBinder(KinesisStreamProvisioner provisioningProvider, software.amazon.awssdk.services.kinesis.KinesisAsyncClient amazonKinesis, KinesisExtendedBindingProperties kinesisExtendedBindingProperties, org.springframework.integration.metadata.ConcurrentMetadataStore kinesisCheckpointStore, org.springframework.integration.support.locks.LockRegistry<?> lockRegistry, software.amazon.awssdk.services.dynamodb.DynamoDbAsyncClient dynamoDBClient, software.amazon.awssdk.services.dynamodb.streams.DynamoDbStreamsClient dynamoDBStreams, software.amazon.awssdk.services.cloudwatch.CloudWatchAsyncClient cloudWatchClient, software.amazon.kinesis.producer.KinesisProducerConfiguration kinesisProducerConfiguration, org.springframework.cloud.stream.config.ProducerMessageHandlerCustomizer<? extends org.springframework.integration.handler.AbstractMessageProducingHandler> producerMessageHandlerCustomizer, org.springframework.cloud.stream.config.ConsumerEndpointCustomizer<? extends org.springframework.integration.endpoint.MessageProducerSupport> consumerEndpointCustomizer, io.micrometer.observation.ObservationRegistry observationRegistry)