Package io.awspring.cloud.sqs.listener.backpressure
package io.awspring.cloud.sqs.listener.backpressure
-
ClassDescriptionAbstraction to handle backpressure within a
PollingMessageSource.Utility class for creatingBackPressureHandlerFactoryinstances used to apply back pressure strategies in SQS listener containers.Factory interface for creatingBackPressureHandlerinstances to manage queue consumption backpressure.BackPressureHandlerspecialization that allows requesting batches.CompositeBackPressureHandlerimplementation that delegates the back-pressure handling to a list ofBackPressureHandlers.A blockingBackPressureHandlerthat limits concurrency using aSemaphore.Non-blockingBackPressureHandlerimplementation that ensures the exact batch size is requested.Deprecated.A non-blockingBackPressureHandlerthat dynamically switches between high- and low-throughput modes to optimize polling behavior based on recent message availability.