Uses of Class
io.awspring.cloud.kinesis.stream.binder.KinesisMessageChannelBinder
Packages that use KinesisMessageChannelBinder
Package
Description
-
Uses of KinesisMessageChannelBinder in io.awspring.cloud.kinesis.stream.binder
Constructors in io.awspring.cloud.kinesis.stream.binder with parameters of type KinesisMessageChannelBinderModifierConstructorDescriptionKinesisBinderHealthIndicator(KinesisMessageChannelBinder kinesisMessageChannelBinder) -
Uses of KinesisMessageChannelBinder in io.awspring.cloud.kinesis.stream.binder.config
Methods in io.awspring.cloud.kinesis.stream.binder.config that return KinesisMessageChannelBinderModifier 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) Methods in io.awspring.cloud.kinesis.stream.binder.config with parameters of type KinesisMessageChannelBinderModifier and TypeMethodDescriptionKinesisBinderConfiguration.KinesisBinderHealthIndicatorConfiguration.kinesisBinderHealthIndicator(KinesisMessageChannelBinder kinesisMessageChannelBinder)