Package io.awspring.cloud.sqs.listener

@NullMarked package io.awspring.cloud.sqs.listener

Components for executing the flow of messages to and from a message listener.

Related Packages

Package	Description
io.awspring.cloud.sqs	SQS integration for Spring Cloud AWS.
io.awspring.cloud.sqs.listener.acknowledgement	Components to process message acknowledgements.
io.awspring.cloud.sqs.listener.adapter	Adapters for invoking a message listener registered by a listener annotation.
io.awspring.cloud.sqs.listener.backpressure
io.awspring.cloud.sqs.listener.errorhandler	Components for handling errors and potentially recovering messages.
io.awspring.cloud.sqs.listener.interceptor	Components for intercepting messages before or after processing.
io.awspring.cloud.sqs.listener.pipeline	Pipeline abstraction to process messages in a container.
io.awspring.cloud.sqs.listener.sink	Components to handle the flow of messages from a Source to a Pipeline.
io.awspring.cloud.sqs.listener.source	Components that provide message instances to be processed.

Class	Description
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>>
AbstractMessageListenerContainer<T,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>>	Base implementation for MessageListenerContainer with SmartLifecycle and component management capabilities.
AbstractPipelineMessageListenerContainer<T,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>>	Base MessageListenerContainer implementation for managing Message instances' lifecycles.
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.
AsyncMessageListener<T>	Async listener to process individual Message instances.
BackPressureMode	Configuration for application throughput.
BatchVisibility	BatchVisibility interface that can be injected as parameter into a listener method.
ConfigurableContainerComponent	Representation of a MessageListenerContainer component that can be configured using a ContainerOptions instance.
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.
DefaultListenerContainerRegistry	MessageListenerContainerRegistry implementation that registers the MessageListenerContainer instances and manage their lifecycle.
FifoBatchGroupingStrategy	Grouping strategy for Fifo SQS with batch listener mode.
FifoSqsComponentFactory<T>	ContainerComponentFactory implementation for creating components for FIFO queues.
IdentifiableContainerComponent	Representation of a component that can be assigned an id.
InterceptorExecutionFailedException	Exception thrown when a MessageInterceptor throws during before-processing execution.
ListenerExecutionFailedException	Exception thrown when the AsyncMessageListener completes with an exception.
ListenerMode	Configure the delivery strategy to be used by a MessageListenerContainer.
MessageListener<T>	Interface to process incoming Messages.
MessageListenerContainer<T>	A container for an AsyncMessageListener with SmartLifecycle capabilities.
MessageListenerContainerRegistry	Interface for registering and looking up containers at startup and runtime.
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.
ObservableComponent	Represents a AbstractPipelineMessageListenerContainer component that can be observed.
QueueAttributes	Queue attributes extracted from SQS, as well as the queue name and url.
QueueAttributesAware	Implementations are enabled to receive a QueueAttributes instance.
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.
SqsAsyncClientAware	Implementations are enabled to receive a SqsAsyncClient instance.
SqsContainerOptions	Sqs specific implementation of ContainerOptions.
SqsContainerOptions.BuilderImpl
SqsContainerOptionsBuilder	ContainerOptionsBuilder specialization for SQS specific options.
SqsHeaders	The MessageHeaders names used for Message instances created from SQS messages.
SqsHeaders.MessageSystemAttributes
SqsMessageListenerContainer<T>	MessageListenerContainer implementation for SQS queues.
SqsMessageListenerContainer.Builder<T>
StandardSqsComponentFactory<T>	A ContainerComponentFactory implementation for Standard SQS queues.
TaskExecutorAware	Enables a class to receive a container managed TaskExecutor.
Visibility	Visibility interface that can be injected as parameter into a listener method.