All Classes and Interfaces

Class	Description
AbstractAfterProcessingInterceptorExecutionStage<T>	Stage responsible for executing the AsyncMessageInterceptors after message processing.
AbstractBeforeProcessingInterceptorExecutionStage<T>	Stage responsible for executing the AsyncMessageInterceptors before message processing.
AbstractContainerOptions<O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>>	Base implementation for ContainerOptions.
AbstractContainerOptions.Builder<B extends ContainerOptionsBuilder<B,O>,O extends ContainerOptions<O,B>>
AbstractDelegatingMessageListeningSinkAdapter<T>	MessageProcessingPipelineSink implementation that delegates method invocations to the provided delegate.
AbstractEndpoint	Base class for implementing a HandlerMethodEndpoint.
AbstractListenerAnnotationBeanPostProcessor<A extends Annotation>	BeanPostProcessor implementation that scans beans for a @SqsListener annotation, extracts information to a SqsEndpoint, and registers it in the EndpointRegistrar.
AbstractListenerObservation	Observation for Message Listener Containers.
AbstractListenerObservation.Context	ReceiverContext for message listeners.
AbstractListenerObservation.Convention<ContextType extends AbstractListenerObservation.Context>	ObservationConvention for message listener key values.
AbstractListenerObservation.Documentation	ObservationDocumentation for message listener keys.
AbstractListenerObservation.Documentation.HighCardinalityTags	High cardinality tags.
AbstractListenerObservation.Documentation.LowCardinalityTags	Low cardinality tags.
AbstractListenerObservation.Specifics<ContextType extends AbstractListenerObservation.Context>	Observation-related instances that are specific to a messaging system.
AbstractMessageConvertingMessageSource<T,S>	A MessageSource implementation capable of converting messages from a Source type to a Target type.
AbstractMessageListenerContainer<T,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>>	Base implementation for MessageListenerContainer with SmartLifecycle and component management capabilities.
AbstractMessageListenerContainerFactory<T,C extends MessageListenerContainer<T>,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>>	Base implementation for a MessageListenerContainerFactory.
AbstractMessageProcessingPipelineSink<T>	Base implementation for MessageProcessingPipelineSink containing SmartLifecycle features and useful execution methods that can be used by subclasses.
AbstractMessagingMessageConverter<S>	Base MessagingMessageConverter implementation.
AbstractMessagingTemplate<S>	Base class for MessagingOperations
AbstractMessagingTemplate.AbstractMessagingTemplateOptions<O extends MessagingTemplateOptions<O>>	Base class for template options, to be extended by subclasses.
AbstractMethodInvokingListenerAdapter<T>	Base class for invoking an InvocableHandlerMethod.
AbstractOrderingAcknowledgementProcessor<T>	Base implementation for a AcknowledgementProcessor with SmartLifecycle capabilities.
AbstractPipelineMessageListenerContainer<T,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>>	Base MessageListenerContainer implementation for managing Message instances' lifecycles.
AbstractPollingMessageSource<T,S>	Base PollingMessageSource implementation with SmartLifecycle capabilities.
AbstractSnsJsonNode
AbstractSqsMessageSource<T>	MessageSource implementation for polling messages from a SQS queue and converting them to messaging Message.
AbstractTemplateObservation	Observation for MessagingOperations.
AbstractTemplateObservation.Context	SenderContext for message listeners.
AbstractTemplateObservation.Convention<ContextType extends AbstractTemplateObservation.Context>	AbstractTemplateObservation.Convention for template key values.
AbstractTemplateObservation.Documentation	ObservationDocumentation for template keys.
AbstractTemplateObservation.Documentation.HighCardinalityTags	High cardinality tags.
AbstractTemplateObservation.Documentation.LowCardinalityTags	Low cardinality tags.
AbstractTemplateObservation.Specifics<ContextType extends AbstractTemplateObservation.Context>	Contains observation-related instances that are specific to a messaging system.
Acknowledgement	Interface representing a message acknowledgement.
AcknowledgementAwareMessageConversionContext	MessageConversionContext specialization that enables setting an AcknowledgementCallback to be used when mapping acknowledgement related properties.
AcknowledgementCallback<T>	Interface representing an acknowledgement callback to be executed, usually by a AcknowledgementHandler implementation.
AcknowledgementExecutor<T>	Allows executing acknowledgements for a batch of messages.
AcknowledgementHandler<T>	Interface for managing acknowledgement in success and failure scenarios.
AcknowledgementHandlerExecutionStage<T>	Stage responsible for executing the AcknowledgementHandler.
AcknowledgementMode	Configures the acknowledgement behavior for this container.
AcknowledgementOrdering	Configures the ordering of acknowledgements.
AcknowledgementProcessingMessageSource<T>	MessageSource specialization that enables processing acknowledgements for the Message instances through an AcknowledgementExecutor
AcknowledgementProcessor<T>	Top-level interface for a component capable of processing acknowledgements.
AcknowledgementResultCallback<T>	Provides actions to be executed after a message acknowledgement completes with either success or failure.
AcknowledgementResultCallbackException	Exception representing a failure to execute a AcknowledgementResultCallback.
AcknowledgmentHandlerMethodArgumentResolver	HandlerMethodArgumentResolver implementation for resolving Acknowledgement arguments.
AfterProcessingContextInterceptorExecutionStage<T>	Stage responsible for executing the AsyncMessageInterceptor instances from the MessageProcessingContext after message processing.
AfterProcessingInterceptorExecutionStage<T>	Stage responsible for executing the AsyncMessageInterceptors after message processing.
AlwaysAcknowledgementHandler<T>	AcknowledgementHandler implementation that acknowledges on both success and error. * @author Tomaz Fernandes
AsyncAcknowledgementResultCallback<T>	Provides actions to be executed after a message acknowledgement completes with either success or failure.
AsyncAdapterBlockingExecutionFailedException	Exception representing a failure on an execution attempted by a blocking adapter.
AsyncComponentAdapters	Utility class for adapting blocking components to their asynchronous variants.
AsyncComponentAdapters.AbstractThreadingComponentAdapter<MessageType>	Base class for BlockingComponentAdapters.
AsyncErrorHandler<T>	Interface for handling message processing errors async.
AsyncMessageInterceptor<T>	Async interface for intercepting messages before and after execution.
AsyncMessageListener<T>	Async listener to process individual Message instances.
AsyncMessagingMessageListenerAdapter<T>	AsyncMessageListener implementation to handle a message by invoking a method handler.
AsyncMessagingOperations	Asynchronous messaging operations.
BackoffVisibilityConstants	Constants for Backoff Error Handler.
BackPressureHandler	Abstraction to handle backpressure within a PollingMessageSource.
BackPressureHandler.ReleaseReason
BackPressureHandlerFactories	Utility class for creating BackPressureHandlerFactory instances used to apply back pressure strategies in SQS listener containers.
BackPressureHandlerFactory	Factory interface for creating BackPressureHandler instances to manage queue consumption backpressure.
BackPressureMode	Configuration for application throughput.
BatchAcknowledgement<T>	Enables acknowledging messages for ListenerMode.BATCH.
BatchAcknowledgmentArgumentResolver	HandlerMethodArgumentResolver implementation for resolving BatchAcknowledgement arguments.
BatchAwareBackPressureHandler	BackPressureHandler specialization that allows requesting batches.
BatchingAcknowledgementProcessor<T>	AcknowledgementProcessor implementation that adds the messages to a BlockingQueue to be acknowledged according to ContainerOptions.getAcknowledgementInterval() and ContainerOptions.getAcknowledgementThreshold().
BatchingSqsClientAdapter	An SqsAsyncClient adapter that provides automatic batching capabilities using AWS SDK's SqsAsyncBatchManager.
BatchMessageSink<T>	MessageSink implementation that emits the whole received batch of messages to the configured MessageProcessingPipeline.
BatchPayloadMethodArgumentResolver	HandlerMethodArgumentResolver implementation for resolving List arguments.
BatchVisibility	BatchVisibility interface that can be injected as parameter into a listener method.
BatchVisibilityHandlerMethodArgumentResolver	HandlerMethodArgumentResolver for BatchVisibility method parameters.
BeforeProcessingContextInterceptorExecutionStage<T>	Stage responsible for executing the AsyncMessageInterceptors from the MessageProcessingContext before message processing.
BeforeProcessingInterceptorExecutionStage<T>	Stage responsible for executing the AsyncMessageInterceptors before message processing.
CollectionUtils
CompletableFutures	Utility methods for using convenient CompletableFuture methods from later JDK versions in Java 8.
CompositeBackPressureHandler	Composite BackPressureHandler implementation that delegates the back-pressure handling to a list of BackPressureHandlers.
CompositeBackPressureHandler.Builder
CompositeInvocableHandler	A composite of InvocableHandlerMethod that delegates message handling to a list of registered handlers, selecting the appropriate one based on the received message payload type.
ConcurrencyLimiterBlockingBackPressureHandler	A blocking BackPressureHandler that limits concurrency using a Semaphore.
ConcurrencyLimiterBlockingBackPressureHandler.Builder
ConfigurableContainerComponent	Representation of a MessageListenerContainer component that can be configured using a ContainerOptions instance.
ConfigUtils	Utility class for conditional configurations.
ContainerComponentFactory<T,O extends ContainerOptions<O,?>>	A factory for creating components for the MessageListenerContainer.
ContainerOptions<O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>>	Contains the options to be used by the MessageListenerContainer at runtime.
ContainerOptionsBuilder<B extends ContainerOptionsBuilder<B,O>,O extends ContainerOptions<O,B>>	A builder for creating a ContainerOptions instance.
ContextAwareHeaderMapper<S>	A HeaderMapper specialization that supports receiving a MessageConversionContext for mapping context dependent headers.
ContextAwareMessagingMessageConverter<S>	A MessagingMessageConverter specialization that enables receving a MessageConversionContext that can be used to add context specific properties to the converted message.
DefaultListenerContainerRegistry	MessageListenerContainerRegistry implementation that registers the MessageListenerContainer instances and manage their lifecycle.
DefaultMessageConverterConfiguration
DefaultMethodPayloadTypeInferrer	Default implementation of MethodPayloadTypeInferrer that infers the payload type by analyzing method parameters and their associated argument resolvers.
Endpoint	Represents a messaging endpoint from which messages can be consumed by a MessageListenerContainer.
EndpointRegistrar	Processes the registered Endpoint instances using the appropriate MessageListenerContainerFactory.
ErrorHandler<T>	Interface for handling errors.
ErrorHandlerExecutionStage<T>	Stage responsible for executing the AsyncErrorHandler after a failed MessageListener execution.
ErrorHandlerVisibilityHelper	Utility methods for Error Handler.
ExceptionUtils	Utilities to handle exceptions.
ExecutingAcknowledgementProcessor<T>	AcknowledgementProcessor specialization that allows for delegating acknowledgement execution to a AcknowledgementExecutor.
ExponentialBackoffErrorHandler<T>	An implementation of an Exponential Backoff error handler for asynchronous message processing.
ExponentialBackoffErrorHandler.Builder<T>
FanOutMessageSink<T>	MessageProcessingPipelineSink implementation that executes messages from the provided batch in parallel.
FifoBatchGroupingStrategy	Grouping strategy for Fifo SQS with batch listener mode.
FifoSqsComponentFactory<T>	ContainerComponentFactory implementation for creating components for FIFO queues.
FifoSqsMessageSource<T>	AbstractSqsMessageSource implementation for FIFO queues.
FifoUtils	Methods related to FIFO queues.
FullBatchBackPressureHandler	Non-blocking BackPressureHandler implementation that ensures the exact batch size is requested.
FullBatchBackPressureHandler.Builder
HandlerMethodEndpoint	Endpoint specialization that indicates that Message instances coming from this endpoint will be handled by a HandlerMethod.
HeaderMapper<S>	Mapper interface to map from and to MessageHeaders and a given source type.
IdentifiableContainerComponent	Representation of a component that can be assigned an id.
ImmediateAcknowledgementProcessor<T>
ImmediateRetryAsyncErrorHandler<T>	A default error handler implementation for asynchronous message processing.
InterceptorExecutionFailedException	Exception thrown when a MessageInterceptor throws during before-processing execution.
JacksonJsonMessageConverterMigration	Deprecated, for removal: This API element is subject to removal in a future version.
JacksonMessageConverterMigration	Deprecated, for removal: This API element is subject to removal in a future version.
Jitter	Strategy interface for applying jitter to exponential backoff calculations.
Jitter.Context	Context for jitter calculations.
LegacyJackson2MessageConverterFactory	Deprecated.
LegacyJackson2MessageConverterMigration	Deprecated, for removal: This API element is subject to removal in a future version.
LegacyJackson2NotificationMessageArgumentResolver	Deprecated.
LegacyJackson2NotificationSubjectArgumentResolver	Deprecated.
LegacyJackson2SnsJsonNode	Deprecated.
LegacyJackson2SnsMessageConverter	Deprecated.
LegacyJackson2SnsNotificationArgumentResolver	Deprecated.
LegacyJackson2SnsNotificationConverter	Deprecated.
LegacyJackson2SnsSubjectConverter	Deprecated.
LegacyJackson2SqsMessagingMessageConverter	Deprecated.
LifecycleHandler	Handler for lifecycle methods.
LinearBackoffErrorHandler<T>	An implementation of a Linear Backoff error handler for asynchronous message processing.
LinearBackoffErrorHandler.Builder<T>
ListenerExecutionFailedException	Exception thrown when the AsyncMessageListener completes with an exception.
ListenerMode	Configure the delivery strategy to be used by a MessageListenerContainer.
MessageAttributeDataTypes
MessageConversionContext	Marker interface for a message conversion context.
MessageConverterFactory	Factory util class to construct MessageConverter Jackson 3 specific.
MessageExecutionThread	A Thread implementation for processing messages.
MessageExecutionThreadFactory	CustomizableThreadFactory implementation for creating MessageExecutionThread instances.
MessageGroupingSinkAdapter<T>	AbstractDelegatingMessageListeningSinkAdapter implementation that groups the received batch according to the provided grouping function and emits each sub batch to the delegate separately.
MessageHeaderContextAccessor	ContextAccessor that use MessageHeaders to hold the Observation context.
MessageHeaderUtils	Utility class for extracting MessageHeaders from a Message.
MessageInterceptor<T>	Interface for intercepting messages before and after execution.
MessageListener<T>	Interface to process incoming Messages.
MessageListenerContainer<T>	A container for an AsyncMessageListener with SmartLifecycle capabilities.
MessageListenerContainerFactory<C extends MessageListenerContainer<?>>	Creates MessageListenerContainer instances for given Endpoint instances or endpoint names.
MessageListenerContainerRegistry	Interface for registering and looking up containers at startup and runtime.
MessageListenerExecutionStage<T>	Stage responsible for executing the AsyncMessageListener.
MessageProcessingConfiguration<T>	Holds the components that will be used on the MessageProcessingPipeline.
MessageProcessingConfiguration.Builder<T>
MessageProcessingContext<T>	A message processing context that can be used for communication between components.
MessageProcessingException	Implemented by exceptions that carry references to the Message instances that failed during processing.
MessageProcessingPipeline<T>	Represents a stage in the processing pipeline that will be used to process Message instances.
MessageProcessingPipelineBuilder<T>	Entrypoint for constructing a MessageProcessingPipeline MessageProcessingPipelineBuilder.ComposingMessagePipelineStage.
MessageProcessingPipelineSink<T>	MessageSink specialization that uses a MessageProcessingPipeline as the output.
MessageSink<T>	Component that handles the flow of Messages.
MessageSource<T>	A source of Message instances.
MessageVisibilityExtendingSinkAdapter<T>	An AbstractDelegatingMessageListeningSinkAdapter that adds an MessageVisibilityExtendingSinkAdapter<T>.io.awspring.cloud.sqs.listener.sink.adapter.MessageVisibilityExtendingSinkAdapter.OriginalBatchMessageVisibilityExtendingInterceptor to the MessageProcessingContext.
MessagingHeaders	MessageHeaders associated with messaging operations.
MessagingMessageConverter<S>	A converter for converting source or target objects to and from Spring Messaging Messages.
MessagingMessageHeaders	MessageHeaders implementation that allows providing an external UUID.
MessagingMessageListenerAdapter<T>	MessageListener implementation to handle a message by invoking a method handler.
MessagingOperationFailedException	Exception to represent the failure of a Messaging Operation.
MessagingOperations	Synchronous messaging operations.
MessagingTemplateOptions<O extends MessagingTemplateOptions<O>>	Options to be used by the template.
MethodPayloadTypeInferrer	Strategy interface for inferring the payload type from a listener method signature.
MultiMethodSqsEndpoint	A SqsEndpoint extension that supports multiple handler methods annotated with SqsHandler
MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
NeverAcknowledgementHandler<T>	AcknowledgementHandler implementation that never acknowledges regardless of the result.
NotificationMessageArgumentResolver
NotificationSubjectArgumentResolver
ObservableComponent	Represents a AbstractPipelineMessageListenerContainer component that can be observed.
OnSuccessAcknowledgementHandler<T>	AcknowledgementHandler implementation that only acknowledges on success.
OrderedMessageSink<T>	MessageProcessingPipelineSink implementation that processes provided messages sequentially and in order.
PollingMessageSource<T>	MessageSource extension that provides polling configurations and SmartLifecycle capabilities.
QueueAttributes	Queue attributes extracted from SQS, as well as the queue name and url.
QueueAttributesAware	Implementations are enabled to receive a QueueAttributes instance.
QueueAttributesMethodArgumentResolver	HandlerMethodArgumentResolver implementation for resolving QueueAttributes arguments.
QueueAttributesResolver	Resolves QueueAttributes for the specified queue.
QueueAttributesResolver.Builder	A builder for creating QueueAttributesResolver instances.
QueueAttributesResolvingException	Exception thrown when a QueueAttributesResolver fails.
QueueMessageBatchVisibility	BatchVisibility implementation for SQS messages.
QueueMessageVisibility	Visibility implementation for SQS messages.
QueueNotFoundStrategy	Configure the strategy to be used when a specified queue is not found at container startup.
SemaphoreBackPressureHandler	Deprecated.
SemaphoreBackPressureHandler.Builder
SendBatchFailureHandlingStrategy	The strategy to use when handling a send batch operation that has at least one failed message.
SendBatchOperationFailedException	Exception representing a partial or complete failure in sending a batch of messages to an endpoint.
SendResult<T>	The result of a send operation.
SendResult.Batch<T>	The result of a batch send operation.
SendResult.Failed<T>	The result of a failed send operation.
SimpleClassMatchingMessageConverter	SmartMessageConverter implementation that returns the payload unchanged if the target class for Serialization / Deserialization matches the payload class.
SnsJsonNode
SnsMessageConverter
SnsNotification<T>	Wrapper for SNS notifications that provides access to both the message payload and metadata.
SnsNotification.MessageAttribute	Represents an SNS message attribute.
SnsNotificationArgumentResolver	Resolves method parameters with SnsNotification object.
SnsNotificationConverter	Converter that extracts SNS notifications from SQS messages and creates SnsNotification objects.
SnsNotificationMessage	Annotation that is used to map SNS notification value on an SQS Queue to a variable that is annotated.
SnsNotificationSubject	Annotation that is used to map SNS notification subject on an SQS Queue to a variable that is annotated.
SnsSubjectConverter
SqsAcknowledgementException	Exception representing an error during acknowledgement execution.
SqsAcknowledgementExecutor<T>	AcknowledgementExecutor implementation for SQS queues.
SqsAsyncClientAware	Implementations are enabled to receive a SqsAsyncClient instance.
SqsAsyncOperations	Sqs-specific asynchronous messaging operations for Standard and Fifo queues.
SqsBeanNames	Utility class containing the bean names used for the framework's bean registration.
SqsBootstrapConfiguration	Registers the DefaultListenerContainerRegistry and EndpointRegistrar that will be used to bootstrap the AWS SQS integration.
SqsContainerOptions	Sqs specific implementation of ContainerOptions.
SqsContainerOptions.BuilderImpl
SqsContainerOptionsBuilder	ContainerOptionsBuilder specialization for SQS specific options.
SqsEndpoint	Endpoint implementation for SQS endpoints.
SqsEndpoint.SqsEndpointBuilder
SqsException	Top-level exception for Sqs RuntimeException instances.
SqsHandler	Methods that are from classes annotated with SqsListener and are annotated with SqsHandler will be marked as the target of the SQS message listener based on the message payload type.
SqsHeaderMapper	A HeaderMapper implementation for SQS Messages.
SqsHeaders	The MessageHeaders names used for Message instances created from SQS messages.
SqsHeaders.MessageSystemAttributes
SqsJacksonVersion	Deprecated, for removal: This API element is subject to removal in a future version.
SqsListener	Methods with this annotation will be wrapped by a MessageListener or AsyncMessageListener and set to a MessageListenerContainer.
SqsListenerAcknowledgementMode	Acknowledgement strategies supported by the SqsListener annotation.
SqsListenerAnnotationBeanPostProcessor	AbstractListenerAnnotationBeanPostProcessor implementation for @SqsListener.
SqsListenerConfigurer	Beans implementing this interface can configure the EndpointRegistrar instance used to process Endpoint instances and change general settings for processing all SqsListener annotations.
SqsListenerObservation	SQS-specific Observation for SqsMessageListenerContainer.
SqsListenerObservation.Context	SqsListenerObservation.Context for SQS message listeners.
SqsListenerObservation.Convention	ObservationConvention for SQS message listener key values.
SqsListenerObservation.DefaultConvention	ObservationConvention for SQS listener key values.
SqsListenerObservation.Documentation	ObservationDocumentation for SQS message listener keys.
SqsListenerObservation.Documentation.HighCardinalityTags	SQS-specific high cardinality tags.
SqsListenerObservation.SqsSpecifics	Observation-related instances that are specific to SQS.
SqsMessageConversionContext	MessageConversionContext implementation that contains SQS related properties for mapping additional MessageHeaders.
SqsMessageDrivenChannelAdapter	The MessageProducerSupport implementation for the Amazon SQS receiveMessage.
SqsMessageHandler	The AbstractMessageProducingHandler implementation for the Amazon SQS.
SqsMessageListenerContainer<T>	MessageListenerContainer implementation for SQS queues.
SqsMessageListenerContainer.Builder<T>
SqsMessageListenerContainerFactory<T>	MessageListenerContainerFactory implementation for creating SqsMessageListenerContainer instances.
SqsMessageListenerContainerFactory.Builder<T>
SqsMessageMethodArgumentResolver	Resolves original SQS message object {@link (software.amazon.awssdk.services.sqs.model.Message)} from Spring Messaging message object Message.
SqsMessagingMessageConverter	MessagingMessageConverter implementation for converting SQS Message instances to Spring Messaging Message instances.
SqsOperations	Sqs-specific synchronous messaging operations for Standard and Fifo queues.
SqsReceiveOptions	Options for receiving messages from SQS queues, with a method chaining API.
SqsSendOptions<T>	Options for sending messages to SQS queues, with a method chaining API.
SqsTemplate	Sqs-specific implementation of AbstractMessagingTemplate
SqsTemplateBuilder	Builder interface for creating a SqsTemplate instance.
SqsTemplateObservation	Observation for SqsTemplate.
SqsTemplateObservation.Context	SqsListenerObservation.Context for SqsTemplate.
SqsTemplateObservation.Convention	ObservationConvention for SqsTemplate key values.
SqsTemplateObservation.DefaultConvention	ObservationConvention for SQS template key values.
SqsTemplateObservation.Documentation	ObservationDocumentation for SqsTemplate keys.
SqsTemplateObservation.Documentation.HighCardinalityTags	High cardinality tags.
SqsTemplateObservation.SqsSpecifics	Observation-related instances that are specific to SQS.
SqsTemplateOptions	Sqs specific options for the SqsTemplate.
SqsTemplateParameters	SQS parameters added to SendResult objects as additional information.
StandardSqsComponentFactory<T>	A ContainerComponentFactory implementation for Standard SQS queues.
StandardSqsMessageSource<T>	AbstractSqsMessageSource implementation for standard queues.
TaskExecutorAware	Enables a class to receive a container managed TaskExecutor.
TemplateAcknowledgementMode	Acknowledgement modes to be used by a MessageReceivingOperations implementation.
TemplateContentBasedDeduplication	The ContentBasedDeduplication queue attribute value to be used by the SqsTemplate when sending messages to a FIFO queue.
ThroughputBackPressureHandler	A non-blocking BackPressureHandler that dynamically switches between high- and low-throughput modes to optimize polling behavior based on recent message availability.
ThroughputBackPressureHandler.Builder
UnsupportedThreadFactoryException	Exception thrown when an executor is provided with an unsupported ThreadFactory.
Visibility	Visibility interface that can be injected as parameter into a listener method.
VisibilityHandlerMethodArgumentResolver	HandlerMethodArgumentResolver for Visibility method parameters.