Uses of Interface
io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler
Packages that use BackPressureHandler
Package
Description
Components for executing the flow of messages to and from a message listener.
Components that provide message instances to be processed.
-
Uses of BackPressureHandler in io.awspring.cloud.sqs.listener
Methods in io.awspring.cloud.sqs.listener that return BackPressureHandlerModifier and TypeMethodDescriptionprotected BackPressureHandlerAbstractPipelineMessageListenerContainer.createBackPressureHandler() -
Uses of BackPressureHandler in io.awspring.cloud.sqs.listener.backpressure
Subinterfaces of BackPressureHandler in io.awspring.cloud.sqs.listener.backpressureModifier and TypeInterfaceDescriptioninterfaceBackPressureHandlerspecialization that allows requesting batches.Classes in io.awspring.cloud.sqs.listener.backpressure that implement BackPressureHandlerModifier and TypeClassDescriptionclassCompositeBackPressureHandlerimplementation that delegates the back-pressure handling to a list ofBackPressureHandlers.classA blockingBackPressureHandlerthat limits concurrency using aSemaphore.classNon-blockingBackPressureHandlerimplementation that ensures the exact batch size is requested.classDeprecated.classA non-blockingBackPressureHandlerthat dynamically switches between high- and low-throughput modes to optimize polling behavior based on recent message availability.Methods in io.awspring.cloud.sqs.listener.backpressure that return BackPressureHandlerModifier and TypeMethodDescriptionBackPressureHandlerFactory.createBackPressureHandler(ContainerOptions<?, ?> containerOptions) Creates a newBackPressureHandlerinstance based on the providedContainerOptions.Method parameters in io.awspring.cloud.sqs.listener.backpressure with type arguments of type BackPressureHandlerModifier and TypeMethodDescriptionCompositeBackPressureHandler.Builder.backPressureHandlers(List<BackPressureHandler> backPressureHandlers) -
Uses of BackPressureHandler in io.awspring.cloud.sqs.listener.source
Methods in io.awspring.cloud.sqs.listener.source with parameters of type BackPressureHandlerModifier and TypeMethodDescriptionvoidAbstractPollingMessageSource.setBackPressureHandler(BackPressureHandler backPressureHandler) voidPollingMessageSource.setBackPressureHandler(BackPressureHandler backPressureHandler) Set theBackPressureHandlerthat will be use to handle backpressure in this source.