Uses of Interface
io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactory
Packages that use BackPressureHandlerFactory
Package
Description
Components for executing the flow of messages to and from a message listener.
-
Uses of BackPressureHandlerFactory in io.awspring.cloud.sqs.listener
Methods in io.awspring.cloud.sqs.listener that return BackPressureHandlerFactoryModifier and TypeMethodDescriptionAbstractContainerOptions.getBackPressureHandlerFactory()ContainerOptions.getBackPressureHandlerFactory()Return theBackPressureHandlerFactoryto create aBackPressureHandlerfor this container.Methods in io.awspring.cloud.sqs.listener with parameters of type BackPressureHandlerFactoryModifier and TypeMethodDescriptionAbstractContainerOptions.Builder.backPressureHandlerFactory(BackPressureHandlerFactory backPressureHandlerFactory) ContainerOptionsBuilder.backPressureHandlerFactory(BackPressureHandlerFactory backPressureHandlerFactory) Sets theBackPressureHandlerFactoryfor this container. -
Uses of BackPressureHandlerFactory in io.awspring.cloud.sqs.listener.backpressure
Methods in io.awspring.cloud.sqs.listener.backpressure that return BackPressureHandlerFactoryModifier and TypeMethodDescriptionstatic BackPressureHandlerFactoryBackPressureHandlerFactories.adaptiveThroughputBackPressureHandler()Creates a factory for an adaptiveBackPressureHandler, combining different strategies based on the providedContainerOptionsand its configuredBackPressureMode.static BackPressureHandlerFactoryBackPressureHandlerFactories.compositeBackPressureHandler(BackPressureHandlerFactory... backPressureHandlerFactories) Creates a newCompositeBackPressureHandlerfrom the given array ofBackPressureHandlerFactoryinstances.static BackPressureHandlerFactoryBackPressureHandlerFactories.compositeBackPressureHandler(List<BackPressureHandlerFactory> factories) Creates a newCompositeBackPressureHandlerfrom the given list ofBackPressureHandlerFactoryinstances.static BackPressureHandlerFactoryBackPressureHandlerFactories.concurrencyLimiterBackPressureHandler()Creates a newConcurrencyLimiterBlockingBackPressureHandlerusing the providedContainerOptions.static BackPressureHandlerFactoryBackPressureHandlerFactories.fullBatchBackPressureHandler()Creates a newFullBatchBackPressureHandlerusing the providedContainerOptions.static BackPressureHandlerFactoryBackPressureHandlerFactories.semaphoreBackPressureHandler()Deprecated.static BackPressureHandlerFactoryBackPressureHandlerFactories.throughputBackPressureHandler()Creates a newThroughputBackPressureHandlerusing the providedContainerOptions.Methods in io.awspring.cloud.sqs.listener.backpressure with parameters of type BackPressureHandlerFactoryModifier and TypeMethodDescriptionstatic BackPressureHandlerFactoryBackPressureHandlerFactories.compositeBackPressureHandler(BackPressureHandlerFactory... backPressureHandlerFactories) Creates a newCompositeBackPressureHandlerfrom the given array ofBackPressureHandlerFactoryinstances.Method parameters in io.awspring.cloud.sqs.listener.backpressure with type arguments of type BackPressureHandlerFactoryModifier and TypeMethodDescriptionstatic BackPressureHandlerFactoryBackPressureHandlerFactories.compositeBackPressureHandler(List<BackPressureHandlerFactory> factories) Creates a newCompositeBackPressureHandlerfrom the given list ofBackPressureHandlerFactoryinstances.