Index (Spring Cloud AWS SQS 4.0.2 API)

A B C D E F G H I J L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

AbstractAfterProcessingInterceptorExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncMessageInterceptors after message processing.
AbstractAfterProcessingInterceptorExecutionStage() - Constructor for class io.awspring.cloud.sqs.listener.pipeline.AbstractAfterProcessingInterceptorExecutionStage
AbstractBeforeProcessingInterceptorExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncMessageInterceptors before message processing.
AbstractBeforeProcessingInterceptorExecutionStage() - Constructor for class io.awspring.cloud.sqs.listener.pipeline.AbstractBeforeProcessingInterceptorExecutionStage
AbstractContainerOptions<O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>> - Class in io.awspring.cloud.sqs.listener: Base implementation for ContainerOptions.
AbstractContainerOptions(AbstractContainerOptions.Builder<?, ?>) - Constructor for class io.awspring.cloud.sqs.listener.AbstractContainerOptions
AbstractContainerOptions.Builder,O extends ContainerOptions<O,B>> - Class in io.awspring.cloud.sqs.listener
AbstractDelegatingMessageListeningSinkAdapter<T> - Class in io.awspring.cloud.sqs.listener.sink.adapter: MessageProcessingPipelineSink implementation that delegates method invocations to the provided delegate.
AbstractDelegatingMessageListeningSinkAdapter(MessageSink<T>) - Constructor for class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter: Create an instance with the provided delegate.
AbstractEndpoint - Class in io.awspring.cloud.sqs.config: Base class for implementing a HandlerMethodEndpoint.
AbstractEndpoint(Collection<String>, String, String) - Constructor for class io.awspring.cloud.sqs.config.AbstractEndpoint
AbstractListenerAnnotationBeanPostProcessor<A extends Annotation> - Class in io.awspring.cloud.sqs.annotation: BeanPostProcessor implementation that scans beans for a @SqsListener annotation, extracts information to a SqsEndpoint, and registers it in the EndpointRegistrar.
AbstractListenerAnnotationBeanPostProcessor() - Constructor for class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
AbstractListenerObservation - Class in io.awspring.cloud.sqs.support.observation: Observation for Message Listener Containers.
AbstractListenerObservation() - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation
AbstractListenerObservation.Context - Class in io.awspring.cloud.sqs.support.observation: ReceiverContext for message listeners.
AbstractListenerObservation.Convention<ContextType extends AbstractListenerObservation.Context> - Class in io.awspring.cloud.sqs.support.observation: ObservationConvention for message listener key values.
AbstractListenerObservation.Documentation - Class in io.awspring.cloud.sqs.support.observation: ObservationDocumentation for message listener keys.
AbstractListenerObservation.Documentation.HighCardinalityTags - Enum Class in io.awspring.cloud.sqs.support.observation: High cardinality tags.
AbstractListenerObservation.Documentation.LowCardinalityTags - Enum Class in io.awspring.cloud.sqs.support.observation: Low cardinality tags.
AbstractListenerObservation.Specifics<ContextType extends AbstractListenerObservation.Context> - Interface in io.awspring.cloud.sqs.support.observation: Observation-related instances that are specific to a messaging system.
AbstractMessageConvertingMessageSource<T,S> - Class in io.awspring.cloud.sqs.listener.source: A MessageSource implementation capable of converting messages from a Source type to a Target type.
AbstractMessageConvertingMessageSource() - Constructor for class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource
AbstractMessageListenerContainer<T,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>> - Class in io.awspring.cloud.sqs.listener: Base implementation for MessageListenerContainer with SmartLifecycle and component management capabilities.
AbstractMessageListenerContainer(O) - Constructor for class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Create an instance with the provided ContainerOptions
AbstractMessageListenerContainerFactory<T,C extends MessageListenerContainer<T>,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>> - Class in io.awspring.cloud.sqs.config: Base implementation for a MessageListenerContainerFactory.
AbstractMessageListenerContainerFactory(O) - Constructor for class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory
AbstractMessageProcessingPipelineSink<T> - Class in io.awspring.cloud.sqs.listener.sink: Base implementation for MessageProcessingPipelineSink containing SmartLifecycle features and useful execution methods that can be used by subclasses.
AbstractMessageProcessingPipelineSink() - Constructor for class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
AbstractMessagingMessageConverter<S> - Class in io.awspring.cloud.sqs.support.converter: Base MessagingMessageConverter implementation.
AbstractMessagingMessageConverter(MessageConverter) - Constructor for class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter
AbstractMessagingTemplate<S> - Class in io.awspring.cloud.sqs.operations: Base class for MessagingOperations
AbstractMessagingTemplate(MessagingMessageConverter<S>, AbstractMessagingTemplate.AbstractMessagingTemplateOptions<?>, AbstractTemplateObservation.Specifics<?>) - Constructor for class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
AbstractMessagingTemplate.AbstractMessagingTemplateOptions<O extends MessagingTemplateOptions<O>> - Class in io.awspring.cloud.sqs.operations: Base class for template options, to be extended by subclasses.
AbstractMessagingTemplateOptions() - Constructor for class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
AbstractMethodInvokingListenerAdapter<T> - Class in io.awspring.cloud.sqs.listener.adapter: Base class for invoking an InvocableHandlerMethod.
AbstractMethodInvokingListenerAdapter(CompositeInvocableHandler) - Constructor for class io.awspring.cloud.sqs.listener.adapter.AbstractMethodInvokingListenerAdapter: Create an instance with the provided CompositeInvocableHandler.
AbstractMethodInvokingListenerAdapter(InvocableHandlerMethod) - Constructor for class io.awspring.cloud.sqs.listener.adapter.AbstractMethodInvokingListenerAdapter: Create an instance with the provided InvocableHandlerMethod.
AbstractOrderingAcknowledgementProcessor<T> - Class in io.awspring.cloud.sqs.listener.acknowledgement: Base implementation for a AcknowledgementProcessor with SmartLifecycle capabilities.
AbstractOrderingAcknowledgementProcessor() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
AbstractPipelineMessageListenerContainer<T,O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>> - Class in io.awspring.cloud.sqs.listener: Base MessageListenerContainer implementation for managing Message instances' lifecycles.
AbstractPipelineMessageListenerContainer(O) - Constructor for class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
AbstractPollingMessageSource<T,S> - Class in io.awspring.cloud.sqs.listener.source: Base PollingMessageSource implementation with SmartLifecycle capabilities.
AbstractPollingMessageSource() - Constructor for class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
AbstractSnsJsonNode - Class in io.awspring.cloud.sqs.support.converter
AbstractSnsJsonNode() - Constructor for class io.awspring.cloud.sqs.support.converter.AbstractSnsJsonNode
AbstractSqsMessageSource<T> - Class in io.awspring.cloud.sqs.listener.source: MessageSource implementation for polling messages from a SQS queue and converting them to messaging Message.
AbstractSqsMessageSource() - Constructor for class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
AbstractTemplateObservation - Class in io.awspring.cloud.sqs.support.observation: Observation for MessagingOperations.
AbstractTemplateObservation() - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation
AbstractTemplateObservation.Context - Class in io.awspring.cloud.sqs.support.observation: SenderContext for message listeners.
AbstractTemplateObservation.Convention<ContextType extends AbstractTemplateObservation.Context> - Class in io.awspring.cloud.sqs.support.observation: AbstractTemplateObservation.Convention for template key values.
AbstractTemplateObservation.Documentation - Class in io.awspring.cloud.sqs.support.observation: ObservationDocumentation for template keys.
AbstractTemplateObservation.Documentation.HighCardinalityTags - Enum Class in io.awspring.cloud.sqs.support.observation: High cardinality tags.
AbstractTemplateObservation.Documentation.LowCardinalityTags - Enum Class in io.awspring.cloud.sqs.support.observation: Low cardinality tags.
AbstractTemplateObservation.Specifics<ContextType extends AbstractTemplateObservation.Context> - Interface in io.awspring.cloud.sqs.support.observation: Contains observation-related instances that are specific to a messaging system.
AbstractThreadingComponentAdapter() - Constructor for class io.awspring.cloud.sqs.listener.AsyncComponentAdapters.AbstractThreadingComponentAdapter
acceptBothIfNoneNull(T, V, BiConsumer<T, V>) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptFirstNonNull(Consumer<T>, T...) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptIfInstance(Object, Class<T>, Consumer<T>) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptIfNotEmpty(Collection<T>, Consumer<Collection<T>>) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptIfNotNull(T, Consumer<T>) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptIfNotNullOrElse(Consumer<T>, T, T) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptMany(Collection<T>, Consumer<T>) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptManyIfInstance(Collection<?>, Class<T>, Consumer<T>) - Method in class io.awspring.cloud.sqs.ConfigUtils
acceptManyIfNotNullAndInstance(T, Collection<?>, Class<V>, BiConsumer<T, V>) - Method in class io.awspring.cloud.sqs.ConfigUtils
ackHandler(AcknowledgementHandler<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder
acknowledge() - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.Acknowledgement: Acknowledge the message.
acknowledge() - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.BatchAcknowledgement: Acknowledge all messages from the batch.
acknowledge(Collection<Message<T>>) - Static method in interface io.awspring.cloud.sqs.listener.acknowledgement.Acknowledgement: Acknowledge the provided messages.
acknowledge(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.BatchAcknowledgement: Acknowledge the provided messages.
acknowledge(Message<?>) - Static method in interface io.awspring.cloud.sqs.listener.acknowledgement.Acknowledgement: Acknowledge the provided message.
ACKNOWLEDGE - Enum constant in enum class io.awspring.cloud.sqs.operations.TemplateAcknowledgementMode: Acknowledge received messages.
acknowledgeAsync() - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.Acknowledgement: Asynchronously acknowledge the message.
acknowledgeAsync() - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.BatchAcknowledgement: Asynchronously acknowledge all messages from the batch.
acknowledgeAsync(Collection<Message<T>>) - Static method in interface io.awspring.cloud.sqs.listener.acknowledgement.Acknowledgement: Acknowledge the provided messages asynchronously.
acknowledgeAsync(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.BatchAcknowledgement: Asynchronously acknowledge the provided messages.
acknowledgeAsync(Message<?>) - Static method in interface io.awspring.cloud.sqs.listener.acknowledgement.Acknowledgement: Acknowledge the provided message asynchronously.
Acknowledgement - Interface in io.awspring.cloud.sqs.listener.acknowledgement: Interface representing a message acknowledgement.
AcknowledgementAwareMessageConversionContext - Interface in io.awspring.cloud.sqs.support.converter: MessageConversionContext specialization that enables setting an AcknowledgementCallback to be used when mapping acknowledgement related properties.
AcknowledgementCallback<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement: Interface representing an acknowledgement callback to be executed, usually by a AcknowledgementHandler implementation.
AcknowledgementExecutor<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement: Allows executing acknowledgements for a batch of messages.
AcknowledgementHandler<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement.handler: Interface for managing acknowledgement in success and failure scenarios.
AcknowledgementHandlerExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AcknowledgementHandler.
AcknowledgementHandlerExecutionStage(MessageProcessingConfiguration<T>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.AcknowledgementHandlerExecutionStage
acknowledgementInterval(Duration) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
acknowledgementInterval(Duration) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the maximum interval between acknowledgements for batch acknowledgements.
acknowledgementMode() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: The acknowledgement mode to be used for the provided queues.
acknowledgementMode(AcknowledgementMode) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
acknowledgementMode(AcknowledgementMode) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
acknowledgementMode(AcknowledgementMode) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the AcknowledgementMode for this container.
acknowledgementMode(TemplateAcknowledgementMode) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
acknowledgementMode(TemplateAcknowledgementMode) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: Set the acknowledgement mode for this template.
AcknowledgementMode - Enum Class in io.awspring.cloud.sqs.listener.acknowledgement.handler: Configures the acknowledgement behavior for this container.
acknowledgementOrdering(AcknowledgementOrdering) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
acknowledgementOrdering(AcknowledgementOrdering) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the AcknowledgementOrdering for this container.
AcknowledgementOrdering - Enum Class in io.awspring.cloud.sqs.listener.acknowledgement: Configures the ordering of acknowledgements.
AcknowledgementProcessingMessageSource<T> - Interface in io.awspring.cloud.sqs.listener.source: MessageSource specialization that enables processing acknowledgements for the Message instances through an AcknowledgementExecutor
AcknowledgementProcessor<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement: Top-level interface for a component capable of processing acknowledgements.
acknowledgementResultCallback(AcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
acknowledgementResultCallback(AcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
acknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
acknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
AcknowledgementResultCallback<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement: Provides actions to be executed after a message acknowledgement completes with either success or failure.
AcknowledgementResultCallbackException - Exception in io.awspring.cloud.sqs.listener.acknowledgement: Exception representing a failure to execute a AcknowledgementResultCallback.
AcknowledgementResultCallbackException(String, Throwable) - Constructor for exception io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementResultCallbackException: Create an instance with the supplied message and cause.
acknowledgementResultTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
acknowledgementResultTaskExecutor(TaskExecutor) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the TaskExecutor to be used by blocking AcknowledgementResultCallback implementations for this container.
acknowledgementShutdownTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
acknowledgementShutdownTimeout(Duration) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the maximum amount of time that the container should wait for batched acknowledgements to finish before shutting down.
acknowledgementThreshold(int) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
acknowledgementThreshold(int) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the threshold for triggering a batch acknowledgement.
ACKNOWLEDGMENT_CALLBACK_HEADER - Static variable in class io.awspring.cloud.sqs.MessagingHeaders: Header for a AcknowledgementCallback for this message.
AcknowledgmentHandlerMethodArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: HandlerMethodArgumentResolver implementation for resolving Acknowledgement arguments.
AcknowledgmentHandlerMethodArgumentResolver() - Constructor for class io.awspring.cloud.sqs.support.resolver.AcknowledgmentHandlerMethodArgumentResolver
acquireTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler.Builder
acquireTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler.Builder: Deprecated.
adapt(AcknowledgementResultCallback<T>) - Static method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters
adapt(ErrorHandler<T>) - Static method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters: Adapt the provided ErrorHandler to an AsyncErrorHandler
adapt(MessageInterceptor<T>) - Static method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters: Adapt the provided MessageInterceptor to an AsyncMessageInterceptor
adapt(MessageListener<T>) - Static method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters: Adapt the provided MessageListener to an AsyncMessageListener
adaptiveThroughputBackPressureHandler() - Static method in class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactories: Creates a factory for an adaptive BackPressureHandler, combining different strategies based on the provided ContainerOptions and its configured BackPressureMode.
addAdditionalHeaders(Message<T>, Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
addHeaderIfAbsent(Message<T>, String, Object) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Add a header to a Message while preserving the id and timestamp.
addHeaderIfAbsent(MessageHeaders, String, Object) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils
addHeadersIfAbsent(Message<T>, Map<String, Object>) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Add headers to a Message while preserving the id and timestamp.
addHeadersIfAbsent(MessageHeaders, Map<String, Object>) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils
addInterceptor(AsyncMessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext
additionalHeader(String, Object) - Method in interface io.awspring.cloud.sqs.operations.SqsReceiveOptions: Provide a header name and value to be added to returned messages.
additionalHeaderForReceive(String, Object) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
additionalHeaderForReceive(String, Object) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: Set a default header to be added to received messages.
additionalHeaders(Map<String, Object>) - Method in interface io.awspring.cloud.sqs.operations.SqsReceiveOptions: Provide headers to be added to returned messages.
additionalHeadersForReceive(Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
additionalHeadersForReceive(Map<String, Object>) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: Set default headers to be added to received messages.
additionalInformation() - Method in record class io.awspring.cloud.sqs.operations.SendResult: Returns the value of the additionalInformation record component.
additionalInformation() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Failed: Returns the value of the additionalInformation record component.
addJacksonMigrationResolvers(List<HandlerMethodArgumentResolver>, MessageConverter) - Method in class io.awspring.cloud.sqs.support.converter.legacy.JacksonJsonMessageConverterMigration: Deprecated.
addJacksonMigrationResolvers(List<HandlerMethodArgumentResolver>, MessageConverter) - Method in interface io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration: Deprecated.
addJacksonMigrationResolvers(List<HandlerMethodArgumentResolver>, MessageConverter) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2MessageConverterMigration: Deprecated.
addMessageInterceptor(AsyncMessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Add a AsyncMessageInterceptor to be used by containers created with this factory.
addMessageInterceptor(AsyncMessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Add an interceptor that will intercept the message before processing.
addMessageInterceptor(MessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Add a MessageInterceptor to be used by containers created with this factory.
addMessageInterceptor(MessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Add a collection of interceptors that will intercept the message before processing.
addTypeToMessages(Collection<Message<?>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
afterProcessing(Collection<Message<T>>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.interceptor.AsyncMessageInterceptor: Perform an action after the listener completes either with success or error.
afterProcessing(Collection<Message<T>>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.interceptor.MessageInterceptor: Perform an action after the listener completes either with success or error.
afterProcessing(Message<T>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.interceptor.AsyncMessageInterceptor: Perform an action after the listener completes either with success or error.
afterProcessing(Message<T>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.interceptor.MessageInterceptor: Perform an action after the listener completes either with success or error.
AfterProcessingContextInterceptorExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncMessageInterceptor instances from the MessageProcessingContext after message processing.
AfterProcessingContextInterceptorExecutionStage(MessageProcessingConfiguration<T>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.AfterProcessingContextInterceptorExecutionStage
AfterProcessingInterceptorExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncMessageInterceptors after message processing.
AfterProcessingInterceptorExecutionStage(MessageProcessingConfiguration<T>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.AfterProcessingInterceptorExecutionStage
afterSingletonsInstantiated() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
afterSingletonsInstantiated() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar
ALWAYS - Enum constant in enum class io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode: Messages will be acknowledged whether processing was completed successfully or with an error.
ALWAYS - Static variable in class io.awspring.cloud.sqs.annotation.SqsListenerAcknowledgementMode: Messages will be acknowledged whether processing was completed successfully or with an error.
ALWAYS_POLL_MAX_MESSAGES - Enum constant in enum class io.awspring.cloud.sqs.listener.BackPressureMode: Enable automatic throughput switching and disable partial batch polling.
AlwaysAcknowledgementHandler<T> - Class in io.awspring.cloud.sqs.listener.acknowledgement.handler: AcknowledgementHandler implementation that acknowledges on both success and error. * @author Tomaz Fernandes
AlwaysAcknowledgementHandler() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.handler.AlwaysAcknowledgementHandler
applyJitter(Jitter.Context) - Method in interface io.awspring.cloud.sqs.listener.errorhandler.Jitter: Apply jitter to the calculated timeout value.
areAllFifo(Collection<String>) - Static method in class io.awspring.cloud.sqs.FifoUtils: Return whether all provided queues are Fifo.
areNotFifo(Collection<String>) - Static method in class io.awspring.cloud.sqs.FifoUtils: Return whether all provided queues are not Fifo.
AsyncAcknowledgementResultCallback<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement: Provides actions to be executed after a message acknowledgement completes with either success or failure.
AsyncAdapterBlockingExecutionFailedException - Exception in io.awspring.cloud.sqs.listener: Exception representing a failure on an execution attempted by a blocking adapter.
AsyncAdapterBlockingExecutionFailedException(String, Throwable) - Constructor for exception io.awspring.cloud.sqs.listener.AsyncAdapterBlockingExecutionFailedException: Create an instance with the provided error message and cause.
AsyncComponentAdapters - Class in io.awspring.cloud.sqs.listener: Utility class for adapting blocking components to their asynchronous variants.
AsyncComponentAdapters.AbstractThreadingComponentAdapter<MessageType> - Class in io.awspring.cloud.sqs.listener: Base class for BlockingComponentAdapters.
AsyncErrorHandler<T> - Interface in io.awspring.cloud.sqs.listener.errorhandler: Interface for handling message processing errors async.
AsyncMessageInterceptor<T> - Interface in io.awspring.cloud.sqs.listener.interceptor: Async interface for intercepting messages before and after execution.
asyncMessageListener(AsyncMessageListener<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
asyncMessageListener(AsyncMessageListener<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
AsyncMessageListener<T> - Interface in io.awspring.cloud.sqs.listener: Async listener to process individual Message instances.
AsyncMessagingMessageListenerAdapter<T> - Class in io.awspring.cloud.sqs.listener.adapter: AsyncMessageListener implementation to handle a message by invoking a method handler.
AsyncMessagingMessageListenerAdapter(InvocableHandlerMethod) - Constructor for class io.awspring.cloud.sqs.listener.adapter.AsyncMessagingMessageListenerAdapter
AsyncMessagingOperations - Interface in io.awspring.cloud.sqs.operations: Asynchronous messaging operations.
AUTO - Enum constant in enum class io.awspring.cloud.sqs.listener.BackPressureMode: Enable automatic throughput switching and partial batch polling.
AUTO - Enum constant in enum class io.awspring.cloud.sqs.operations.TemplateContentBasedDeduplication: The ContentBasedDeduplication queue attribute value will be resolved automatically at runtime.
autoStartup(boolean) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
autoStartup(boolean) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set whether the container should be started automatically or manually.

B

BackoffVisibilityConstants - Class in io.awspring.cloud.sqs.listener.errorhandler: Constants for Backoff Error Handler.
BackoffVisibilityConstants() - Constructor for class io.awspring.cloud.sqs.listener.errorhandler.BackoffVisibilityConstants
BackPressureHandler - Interface in io.awspring.cloud.sqs.listener.backpressure: Abstraction to handle backpressure within a PollingMessageSource.
BackPressureHandler.ReleaseReason - Enum Class in io.awspring.cloud.sqs.listener.backpressure
BackPressureHandlerFactories - Class in io.awspring.cloud.sqs.listener.backpressure: Utility class for creating BackPressureHandlerFactory instances used to apply back pressure strategies in SQS listener containers.
backPressureHandlerFactory(BackPressureHandlerFactory) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
backPressureHandlerFactory(BackPressureHandlerFactory) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Sets the BackPressureHandlerFactory for this container.
BackPressureHandlerFactory - Interface in io.awspring.cloud.sqs.listener.backpressure: Factory interface for creating BackPressureHandler instances to manage queue consumption backpressure.
backPressureHandlers(List<BackPressureHandler>) - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler.Builder
backPressureMode(BackPressureMode) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
backPressureMode(BackPressureMode) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the BackPressureMode for this container.
BackPressureMode - Enum Class in io.awspring.cloud.sqs.listener: Configuration for application throughput.
Batch(Collection<SendResult<T>>, Collection<SendResult.Failed<T>>) - Constructor for record class io.awspring.cloud.sqs.operations.SendResult.Batch: Creates an instance of a Batch record class.
BATCH - Enum constant in enum class io.awspring.cloud.sqs.listener.ListenerMode: Configure the container to receive the whole batch of messages in its components.
BatchAcknowledgement<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement: Enables acknowledging messages for ListenerMode.BATCH.
BatchAcknowledgmentArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: HandlerMethodArgumentResolver implementation for resolving BatchAcknowledgement arguments.
BatchAcknowledgmentArgumentResolver() - Constructor for class io.awspring.cloud.sqs.support.resolver.BatchAcknowledgmentArgumentResolver
BatchAwareBackPressureHandler - Interface in io.awspring.cloud.sqs.listener.backpressure: BackPressureHandler specialization that allows requesting batches.
BatchingAcknowledgementProcessor<T> - Class in io.awspring.cloud.sqs.listener.acknowledgement: AcknowledgementProcessor implementation that adds the messages to a BlockingQueue to be acknowledged according to ContainerOptions.getAcknowledgementInterval() and ContainerOptions.getAcknowledgementThreshold().
BatchingAcknowledgementProcessor() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
BatchingSqsClientAdapter - Class in io.awspring.cloud.sqs.operations: An SqsAsyncClient adapter that provides automatic batching capabilities using AWS SDK's SqsAsyncBatchManager.
BatchingSqsClientAdapter(SqsAsyncBatchManager) - Constructor for class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Creates a new BatchingSqsClientAdapter with the specified batch manager.
BatchMessageSink<T> - Class in io.awspring.cloud.sqs.listener.sink: MessageSink implementation that emits the whole received batch of messages to the configured MessageProcessingPipeline.
BatchMessageSink() - Constructor for class io.awspring.cloud.sqs.listener.sink.BatchMessageSink
BatchPayloadMethodArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: HandlerMethodArgumentResolver implementation for resolving List arguments.
BatchPayloadMethodArgumentResolver(MessageConverter) - Constructor for class io.awspring.cloud.sqs.support.resolver.BatchPayloadMethodArgumentResolver: Create a new BatchPayloadArgumentResolver with the given MessageConverter.
BatchPayloadMethodArgumentResolver(MessageConverter, Validator) - Constructor for class io.awspring.cloud.sqs.support.resolver.BatchPayloadMethodArgumentResolver: Create a new BatchPayloadArgumentResolver with the given MessageConverter and Validator.
batchSize(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler.Builder
batchSize(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler.Builder
batchSize(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler.Builder
batchSize(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler.Builder: Deprecated.
batchSize(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler.Builder
BatchVisibility - Interface in io.awspring.cloud.sqs.listener: BatchVisibility interface that can be injected as parameter into a listener method.
BatchVisibilityHandlerMethodArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: HandlerMethodArgumentResolver for BatchVisibility method parameters.
BatchVisibilityHandlerMethodArgumentResolver(String) - Constructor for class io.awspring.cloud.sqs.support.resolver.BatchVisibilityHandlerMethodArgumentResolver
bean(Object) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
BeforeProcessingContextInterceptorExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncMessageInterceptors from the MessageProcessingContext before message processing.
BeforeProcessingContextInterceptorExecutionStage(MessageProcessingConfiguration<T>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.BeforeProcessingContextInterceptorExecutionStage
BeforeProcessingInterceptorExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncMessageInterceptors before message processing.
BeforeProcessingInterceptorExecutionStage(MessageProcessingConfiguration<T>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.BeforeProcessingInterceptorExecutionStage
BINARY - Static variable in class io.awspring.cloud.sqs.support.converter.MessageAttributeDataTypes: Binary message attribute data type.
build() - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
build() - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
build() - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
build() - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler.Builder
build() - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler.Builder
build() - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler.Builder
build() - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler.Builder: Deprecated.
build() - Method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler.Builder
build() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Create the ContainerOptions instance.
build() - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler.Builder
build() - Method in class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler.Builder
build() - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder
build() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
build() - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
build() - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Create the template with the provided options, exposing both sync and async methods.
build() - Method in class io.awspring.cloud.sqs.QueueAttributesResolver.Builder: Build the QueueAttributesResolver instance with the provided settings.
build(MessageProcessingConfiguration<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder
buildAsyncTemplate() - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Create the template with the provided options, exposing only the async methods contained in the SqsAsyncOperations interface.
builder() - Static method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint
builder() - Static method in class io.awspring.cloud.sqs.config.SqsEndpoint: Return a SqsEndpoint.SqsEndpointBuilder instance with the provided queue names.
builder() - Static method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory
builder() - Static method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler
builder() - Static method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler
builder() - Static method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler
builder() - Static method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
builder() - Static method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler
builder() - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler
builder() - Static method in class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler
builder() - Static method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration
builder() - Static method in class io.awspring.cloud.sqs.listener.SqsContainerOptions: Create a new builder instance.
builder() - Static method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
builder() - Static method in class io.awspring.cloud.sqs.operations.SqsTemplate: Create a new SqsTemplateBuilder.
builder() - Static method in class io.awspring.cloud.sqs.QueueAttributesResolver
Builder() - Constructor for class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler.Builder: Deprecated.
Builder() - Constructor for class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
Builder() - Constructor for class io.awspring.cloud.sqs.QueueAttributesResolver.Builder
Builder(AbstractContainerOptions<?, ?>) - Constructor for class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
BuilderImpl() - Constructor for class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
BuilderImpl(SqsContainerOptions) - Constructor for class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
buildSyncTemplate() - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Create the template with the provided options, exposing only the sync methods contained in the SqsOperations interface.

C

calculateVisibilityTimeoutExponentially(long, int, double, int) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
calculateVisibilityTimeoutLinearly(long, int, int, int) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
castFromCollection(Collection<Message<?>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
castFromOptional(Optional<Message<?>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
castMessages(Collection<Message<T>>) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
changeMessageVisibility(Consumer<ChangeMessageVisibilityRequest.Builder>) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Changes the visibility timeout of a message in the specified SQS queue using automatic batching.
changeMessageVisibility(ChangeMessageVisibilityRequest) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Changes the visibility timeout of a message in the specified SQS queue using automatic batching.
changeTo(int) - Method in interface io.awspring.cloud.sqs.listener.BatchVisibility: Changes the provided messages visibility to the provided value.
changeTo(int) - Method in interface io.awspring.cloud.sqs.listener.Visibility: Changes the message visibility to the provided value.
changeToAsync(int) - Method in interface io.awspring.cloud.sqs.listener.BatchVisibility: Asynchronously changes the provided messages visibility to the provided value.
changeToAsync(int) - Method in class io.awspring.cloud.sqs.listener.QueueMessageBatchVisibility
changeToAsync(int) - Method in class io.awspring.cloud.sqs.listener.QueueMessageVisibility
changeToAsync(int) - Method in interface io.awspring.cloud.sqs.listener.Visibility: Asynchronously changes the message visibility to the provided value.
checkVisibilityTimeout(long) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
close() - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Closes the underlying batch manager and releases associated resources.
CollectionUtils - Class in io.awspring.cloud.sqs
CollectionUtils() - Constructor for class io.awspring.cloud.sqs.CollectionUtils
CompletableFutures - Class in io.awspring.cloud.sqs: Utility methods for using convenient CompletableFuture methods from later JDK versions in Java 8.
componentFactories(Collection<ContainerComponentFactory<T, SqsContainerOptions>>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
componentsTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
componentsTaskExecutor(TaskExecutor) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the TaskExecutor to be used by this container's components.
compositeBackPressureHandler(BackPressureHandlerFactory...) - Static method in class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactories: Creates a new CompositeBackPressureHandler from the given array of BackPressureHandlerFactory instances.
compositeBackPressureHandler(List<BackPressureHandlerFactory>) - Static method in class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactories: Creates a new CompositeBackPressureHandler from the given list of BackPressureHandlerFactory instances.
CompositeBackPressureHandler - Class in io.awspring.cloud.sqs.listener.backpressure: Composite BackPressureHandler implementation that delegates the back-pressure handling to a list of BackPressureHandlers.
CompositeBackPressureHandler.Builder - Class in io.awspring.cloud.sqs.listener.backpressure
CompositeInvocableHandler - Class in io.awspring.cloud.sqs.listener.adapter: 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.
CompositeInvocableHandler(List<InvocableHandlerMethod>, InvocableHandlerMethod) - Constructor for class io.awspring.cloud.sqs.listener.adapter.CompositeInvocableHandler: Create a new CompositeInvocableHandler instance with the given handlers.
CompositeInvocableHandler(InvocableHandlerMethod) - Constructor for class io.awspring.cloud.sqs.listener.adapter.CompositeInvocableHandler: Create a new CompositeInvocableHandler instance with the given handler.
concurrencyLimiterBackPressureHandler() - Static method in class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactories: Creates a new ConcurrencyLimiterBlockingBackPressureHandler using the provided ContainerOptions.
ConcurrencyLimiterBlockingBackPressureHandler - Class in io.awspring.cloud.sqs.listener.backpressure: A blocking BackPressureHandler that limits concurrency using a Semaphore.
ConcurrencyLimiterBlockingBackPressureHandler.Builder - Class in io.awspring.cloud.sqs.listener.backpressure
ConfigurableContainerComponent - Interface in io.awspring.cloud.sqs.listener: Representation of a MessageListenerContainer component that can be configured using a ContainerOptions instance.
configure(EndpointRegistrar) - Method in interface io.awspring.cloud.sqs.config.SqsListenerConfigurer: Configures the EndpointRegistrar instance that will handle the Endpoint instances.
configure(ConfigurableContainerComponent) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Configure a ConfigurableContainerComponent with this options.
configure(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
configure(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
configure(ContainerOptions<?, ?>) - Method in interface io.awspring.cloud.sqs.listener.ConfigurableContainerComponent: Configure the component with the provided ContainerOptions instance
configure(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
configure(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource
configure(Collection<? extends ConfigurableContainerComponent>) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Configure a collection of ConfigurableContainerComponent with this options.
configure(Consumer) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Allows configuring this factories' ContainerOptionsBuilder.
configure(Consumer) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Returns the ContainerOptions instance for this container.
configure(Consumer<SqsContainerOptionsBuilder>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
configure(Consumer<SqsContainerOptionsBuilder>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
configure(Consumer<SqsTemplateOptions>) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Configure options for the template.
configureAbstractContainer(AbstractMessageListenerContainer<T, O, B>, Endpoint) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory
configureBatchingAcknowledgementProcessor(SqsContainerOptions, BatchingAcknowledgementProcessor<T>) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
configureBatchingAckProcessor(SqsContainerOptions, BatchingAcknowledgementProcessor<T>) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
configureContainer(C, Endpoint) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory
configureContainerComponents() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
configureContainerOptions(Endpoint, B) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory
configureContainerOptions(Endpoint, SqsContainerOptionsBuilder) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory
configureDefaultConverter(Consumer<AbstractMessagingMessageConverter>) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Configure the default message converter.
configureDefaultConverter(Consumer<AbstractMessagingMessageConverter>, SqsJacksonVersion) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Configure the default message converter.
configureDefaultHandlerMethodFactory(DefaultMessageHandlerMethodFactory) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
configureImmediateAcknowledgementProcessor(ImmediateAcknowledgementProcessor<T>, SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
configureImmediateProcessor(ImmediateAcknowledgementProcessor<T>, SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
configureLegacyObjectMapper(MessagingMessageConverter) - Method in interface io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration: Deprecated.
configureLegacyObjectMapper(MessagingMessageConverter) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2MessageConverterMigration: Deprecated.
configureListenerMode(Consumer<ListenerMode>) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint
configureListenerMode(Consumer<ListenerMode>) - Method in interface io.awspring.cloud.sqs.config.HandlerMethodEndpoint: Allows configuring the ListenerMode for this endpoint.
configureMessageSink(MessageProcessingPipeline<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
configureMessageSource(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource
configureMessageSource(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
configureMessageSources(ContainerComponentFactory<T, O>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
ConfigUtils - Class in io.awspring.cloud.sqs: Utility class for conditional configurations.
containerComponentFactories(Collection<ContainerComponentFactory<T, SqsContainerOptions>>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
ContainerComponentFactory<T,O extends ContainerOptions<O,?>> - Interface in io.awspring.cloud.sqs.listener: A factory for creating components for the MessageListenerContainer.
ContainerOptions<O extends ContainerOptions<O,B>,B extends ContainerOptionsBuilder<B,O>> - Interface in io.awspring.cloud.sqs.listener: Contains the options to be used by the MessageListenerContainer at runtime.
ContainerOptionsBuilder,O extends ContainerOptions<O,B>> - Interface in io.awspring.cloud.sqs.listener: A builder for creating a ContainerOptions instance.
contentBasedDeduplication(TemplateContentBasedDeduplication) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateOptions: Set the ContentBasedDeduplication queue attribute value of the queues the template is sending messages to.
Context(int, Supplier<Random>) - Constructor for class io.awspring.cloud.sqs.listener.errorhandler.Jitter.Context: Create a new Context instance.
Context(Message<?>) - Constructor for class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Context: Construct an SQS message receiver context.
Context(Message<?>, String) - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Context: Build a messaging receiver context.
Context(Message<?>, String) - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Context: Build a messaging sender context.
Context(Message<?>, String) - Constructor for class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Context: Construct an SQS message sender context.
ContextAwareHeaderMapper<S> - Interface in io.awspring.cloud.sqs.support.converter: A HeaderMapper specialization that supports receiving a MessageConversionContext for mapping context dependent headers.
ContextAwareMessagingMessageConverter<S> - Interface in io.awspring.cloud.sqs.support.converter: A MessagingMessageConverter specialization that enables receving a MessageConversionContext that can be used to add context specific properties to the converted message.
Convention() - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
Convention() - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
convertFromInternal(Message<?>, Class<?>, Object) - Method in class io.awspring.cloud.sqs.support.converter.SimpleClassMatchingMessageConverter
convertMessage(S) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource
convertMessages(Collection<S>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource
convertToInternal(Object, MessageHeaders, Object) - Method in class io.awspring.cloud.sqs.support.converter.SimpleClassMatchingMessageConverter
create() - Static method in class io.awspring.cloud.sqs.listener.MessageProcessingContext
CREATE - Enum constant in enum class io.awspring.cloud.sqs.listener.QueueNotFoundStrategy: Create queues that are not found at startup.
createAcknowledgementExecutorInstance() - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
createAcknowledgementHandler(O) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory: Create a AcknowledgementHandler instance based on the given ContainerOptions
createAcknowledgementProcessor() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
createAcknowledgementProcessor(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
createAcknowledgementProcessor(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
createAcknowledgementProcessor(O) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory: Create an AcknowledgementProcessor instance.
createAdditionalArgumentResolvers() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
createAdditionalArgumentResolvers() - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
createAdditionalArgumentResolvers(MessageConverter, JacksonMessageConverterMigration) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
createAdditionalArgumentResolvers(MessageConverter, JacksonMessageConverterMigration) - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
createAndConfigureAcknowledgementExecutor(QueueAttributes) - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
createAndConfigureImmediateProcessor(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
createArgumentResolvers(MessageConverter) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
createAsyncMessageListenerInstance(InvocableHandlerMethod) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint
createBackPressureHandler() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createBackPressureHandler(ContainerOptions<?, ?>) - Method in interface io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactory: Creates a new BackPressureHandler instance based on the provided ContainerOptions.
createBatchingProcessorInstance() - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
createBatchingProcessorInstance() - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
createCompositeMessageConverter() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
createContainer(Endpoint) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory
createContainer(Endpoint) - Method in interface io.awspring.cloud.sqs.config.MessageListenerContainerFactory: Create a container instance for the given Endpoint.
createContainer(String...) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory
createContainer(String...) - Method in interface io.awspring.cloud.sqs.config.MessageListenerContainerFactory: Create a container instance for the given endpoint names.
createContainerInstance(Endpoint, SqsContainerOptions) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory
createContainerInstance(Endpoint, O) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory
createContext() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
createContext(Message<?>) - Method in interface io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Specifics: Construct an specific AbstractListenerObservation.Context instance with the provided message.
createContext(Message<?>) - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.SqsSpecifics
createContext(Message<?>, String) - Method in interface io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Specifics: Construct an specific AbstractListenerObservation.Context instance with the provided message.
createContext(Message<?>, String) - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.SqsSpecifics
createContextHeaders(Message, MessageConversionContext) - Method in class io.awspring.cloud.sqs.support.converter.SqsHeaderMapper
createContextHeaders(S, MessageConversionContext) - Method in interface io.awspring.cloud.sqs.support.converter.ContextAwareHeaderMapper
createCopy() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Create a copy of this options.
createCopy() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Create a copy of this builder.
createCopy() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
createDefaultComponentFactories() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createDefaultComponentFactories() - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
createDefaultHeaderMapper() - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter
createDefaultHeaderMapper() - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SqsMessagingMessageConverter: Deprecated.
createDefaultHeaderMapper() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter
createDefaultMappingJacksonMessageConverter() - Static method in class io.awspring.cloud.sqs.config.MessageConverterFactory
createDefaultMappingLegacyJackson2MessageConverter() - Static method in class io.awspring.cloud.sqs.config.legacy.LegacyJackson2MessageConverterFactory: Deprecated.
createDefaultMessageConverter() - Static method in class io.awspring.cloud.sqs.DefaultMessageConverterConfiguration
createEndpoint(A) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
createEndpoint(SqsListener) - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
createEndpointRegistrar() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
createImmediateProcessorInstance() - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
createImmediateProcessorInstance() - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
createJacksonJsonMessageConverter(JsonMapper) - Static method in class io.awspring.cloud.sqs.config.MessageConverterFactory
createLegacyJackson2MessageConverter(ObjectMapper) - Static method in class io.awspring.cloud.sqs.config.legacy.LegacyJackson2MessageConverterFactory: Deprecated.
createListenerException(Collection<Message<T>>, Throwable) - Method in class io.awspring.cloud.sqs.listener.adapter.AbstractMethodInvokingListenerAdapter
createListenerException(Message<T>, Throwable) - Method in class io.awspring.cloud.sqs.listener.adapter.AbstractMethodInvokingListenerAdapter
createMessageConversionContext() - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter
createMessageConversionContext() - Method in interface io.awspring.cloud.sqs.support.converter.ContextAwareMessagingMessageConverter: An optional context to be used in the conversion process.
createMessageConversionContext() - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SqsMessagingMessageConverter: Deprecated.
createMessageConversionContext() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter
createMessageListenerInstance(CompositeInvocableHandler) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint
createMessageListenerInstance(InvocableHandlerMethod) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint
createMessageProcessingPipeline(ContainerComponentFactory<T, O>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createMessageSink(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
createMessageSink(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
createMessageSink(O) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory: Create a MessageSink instance.
createMessageSource(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
createMessageSource(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
createMessageSource(String, int, ContainerComponentFactory<T, O>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createMessageSource(O) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory: Create a MessageSource instance.
createMessageSources(ContainerComponentFactory<T, O>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createMessagingObservationSpecifics() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createMessagingObservationSpecifics() - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
createMigrationMessageConverter() - Method in class io.awspring.cloud.sqs.support.converter.legacy.JacksonJsonMessageConverterMigration: Deprecated.
createMigrationMessageConverter() - Method in interface io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration: Deprecated.
createMigrationMessageConverter() - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2MessageConverterMigration: Deprecated.
createMultiMethodEndpoint(A, List<Method>, Method, Object) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
createMultiMethodEndpoint(SqsListener, List<Method>, Method, Object) - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
createSourcesTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
createTaskScheduler() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
createThread(Runnable) - Method in class io.awspring.cloud.sqs.MessageExecutionThreadFactory
createThreadFactory() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
customizeRequest(ReceiveMessageRequest.Builder) - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
customizeRequest(ReceiveMessageRequest.Builder) - Method in class io.awspring.cloud.sqs.listener.source.FifoSqsMessageSource

D

DEFAULT_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class io.awspring.cloud.sqs.config.EndpointRegistrar
DEFAULT_PHASE - Static variable in interface io.awspring.cloud.sqs.listener.MessageListenerContainer
DEFAULT_SEND_TIMEOUT - Static variable in class io.awspring.cloud.sqs.integration.SqsMessageHandler
DefaultConvention() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.DefaultConvention
DefaultConvention() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.DefaultConvention
defaultEndpointName(String) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions: Subclasses should have a method with a more specific name and delegate to this.
DefaultListenerContainerRegistry - Class in io.awspring.cloud.sqs.listener: MessageListenerContainerRegistry implementation that registers the MessageListenerContainer instances and manage their lifecycle.
DefaultListenerContainerRegistry() - Constructor for class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
defaultMaxNumberOfMessages(Integer) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
defaultMaxNumberOfMessages(Integer) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: Set the default maximum number of messages to be retrieved in a single batch.
DefaultMessageConverterConfiguration - Class in io.awspring.cloud.sqs
DefaultMessageConverterConfiguration() - Constructor for class io.awspring.cloud.sqs.DefaultMessageConverterConfiguration
defaultMethod(Method) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
DefaultMethodPayloadTypeInferrer - Class in io.awspring.cloud.sqs.config: Default implementation of MethodPayloadTypeInferrer that infers the payload type by analyzing method parameters and their associated argument resolvers.
DefaultMethodPayloadTypeInferrer() - Constructor for class io.awspring.cloud.sqs.config.DefaultMethodPayloadTypeInferrer
defaultPayloadClass(Class<?>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
defaultPayloadClass(Class<?>) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: The default class to which this template should convert payloads to.
defaultPollTimeout(Duration) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
defaultPollTimeout(Duration) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: Set the default maximum amount of time this template will wait for the maximum number of messages before returning.
defaultQueue(String) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateOptions: Set the default queue for this template.
delaySeconds(Integer) - Method in interface io.awspring.cloud.sqs.operations.SqsSendOptions: Set a delay for the message in seconds.
deleteMessage(Consumer<DeleteMessageRequest.Builder>) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Deletes a message from the specified SQS queue using automatic batching.
deleteMessage(DeleteMessageRequest) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Deletes a message from the specified SQS queue using automatic batching.
detectAnnotationsAndRegisterEndpoints(Object, Class<?>) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
DISABLED - Enum constant in enum class io.awspring.cloud.sqs.operations.TemplateContentBasedDeduplication: ContentBasedDeduplication is disabled on all FIFO SQS queues.
dispose(Object) - Method in class io.awspring.cloud.sqs.LifecycleHandler: Execute the DisposableBean.destroy() method if the provided object is a DisposableBean instance.
DO_NOT_THROW - Enum constant in enum class io.awspring.cloud.sqs.operations.SendBatchFailureHandlingStrategy: Do not throw an exception and return the SendResult.Batch object directly.
doAcknowledgeMessages(String, Collection<Message<?>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
doAcknowledgeMessages(String, Collection<Message<?>>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
doConfigure(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
doConfigure(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
doConfigure(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource: Override to configure subclasses.
doConfigure(ContainerOptions<?, ?>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
doConfigureMessageSink(MessageSink<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
doConfigureMessageSink(MessageSink<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
doConfigureMessageSources(Collection<MessageSource<T>>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
doConfigureMessageSources(Collection<MessageSource<T>>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
doConfigurePayloadTypeOnContext(Class<?>, MessageConversionContext) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource: Hook method for subclasses to configure the payload type on their specific MessageConversionContext implementation.
doConfigurePayloadTypeOnContext(Class<?>, MessageConversionContext) - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
doConvertMessage(Message, Object) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SqsMessagingMessageConverter: Deprecated.
doConvertMessage(Message, Object) - Method in class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter
doConvertMessage(S, Object) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter
Documentation() - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation
Documentation() - Constructor for class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation
Documentation() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Documentation
Documentation() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Documentation
doEmit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
doEmit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.BatchMessageSink
doEmit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.FanOutMessageSink
doEmit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.OrderedMessageSink
doNotSendPayloadTypeHeader() - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Configure the converter to not include payload type information in the Message headers.
doOnAcknowledge(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
doOnAcknowledge(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
doOnAcknowledge(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.ImmediateAcknowledgementProcessor
doOnAcknowledge(Message<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
doOnAcknowledge(Message<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
doOnAcknowledge(Message<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.ImmediateAcknowledgementProcessor
doPollForMessages(int) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
doPollForMessages(int) - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
doReceiveAsync(String, Duration, Integer, Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
doReceiveAsync(String, Duration, Integer, Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
doSendAsync(String, Message, Message<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
doSendAsync(String, S, Message<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
doSendBatchAsync(String, Collection<S>, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
doSendBatchAsync(String, Collection<Message>, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
doStart() - Method in class io.awspring.cloud.sqs.integration.SqsMessageDrivenChannelAdapter
doStart() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
doStart() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
doStart() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
doStart() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
doStart() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
doStart() - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
doStop() - Method in class io.awspring.cloud.sqs.integration.SqsMessageDrivenChannelAdapter
doStop() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
doStop() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
doStop() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
doStop() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
doStop() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
drain(Duration) - Method in interface io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler: Attempts to acquire all permits up to the specified timeout.
drain(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler
drain(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler
drain(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler
drain(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
drain(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler

E

emit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
emit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.MessageGroupingSinkAdapter
emit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.MessageVisibilityExtendingSinkAdapter
emit(Collection<Message<T>>, MessageProcessingContext<T>) - Method in interface io.awspring.cloud.sqs.listener.sink.MessageSink: Emit the provided Message instances to the provided AsyncMessageListener.
ENABLED - Enum constant in enum class io.awspring.cloud.sqs.operations.TemplateContentBasedDeduplication: ContentBasedDeduplication is enabled on all FIFO SQS queues.
endpoint() - Method in record class io.awspring.cloud.sqs.operations.SendResult: Returns the value of the endpoint record component.
endpoint() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Failed: Returns the value of the endpoint record component.
Endpoint - Interface in io.awspring.cloud.sqs.config: Represents a messaging endpoint from which messages can be consumed by a MessageListenerContainer.
ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class io.awspring.cloud.sqs.config.SqsBeanNames: The bean name of the DefaultListenerContainerRegistry registered by SqsBootstrapConfiguration.
EndpointRegistrar - Class in io.awspring.cloud.sqs.config: Processes the registered Endpoint instances using the appropriate MessageListenerContainerFactory.
EndpointRegistrar() - Constructor for class io.awspring.cloud.sqs.config.EndpointRegistrar
enrichResolversDefault(List<HandlerMethodArgumentResolver>, MessageConverter) - Static method in class io.awspring.cloud.sqs.support.converter.legacy.JacksonJsonMessageConverterMigration: Deprecated.
enrichResolversDefault(List<HandlerMethodArgumentResolver>, MessageConverter) - Static method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2MessageConverterMigration: Deprecated.
equals(Object) - Method in record class io.awspring.cloud.sqs.operations.SendResult.Batch: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.awspring.cloud.sqs.operations.SendResult: Indicates whether some other object is "equal to" this one.
equals(Object) - Method in record class io.awspring.cloud.sqs.operations.SendResult.Failed: Indicates whether some other object is "equal to" this one.
ERROR_CODE_PARAMETER_NAME - Static variable in class io.awspring.cloud.sqs.operations.SqsTemplateParameters: A code representing the error.
errorHandler(AsyncErrorHandler<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
errorHandler(AsyncErrorHandler<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder
errorHandler(AsyncErrorHandler<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
errorHandler(ErrorHandler<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
errorHandler(ErrorHandler<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
ErrorHandler<T> - Interface in io.awspring.cloud.sqs.listener.errorhandler: Interface for handling errors.
ErrorHandlerExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncErrorHandler after a failed MessageListener execution.
ErrorHandlerExecutionStage(MessageProcessingConfiguration<T>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.ErrorHandlerExecutionStage
ErrorHandlerVisibilityHelper - Class in io.awspring.cloud.sqs.listener.errorhandler: Utility methods for Error Handler.
ErrorHandlerVisibilityHelper() - Constructor for class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
errorMessage() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Failed: Returns the value of the errorMessage record component.
exceptionallyCompose(CompletableFuture<T>, Function<Throwable, ? extends CompletableFuture<T>>) - Static method in class io.awspring.cloud.sqs.CompletableFutures: Compose the provided future with a function that returns another completable future that is executed exceptionally.
ExceptionUtils - Class in io.awspring.cloud.sqs: Utilities to handle exceptions.
ExceptionUtils() - Constructor for class io.awspring.cloud.sqs.ExceptionUtils
execute(Runnable) - Method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters.AbstractThreadingComponentAdapter
execute(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementExecutor: Executes acknowledgements for the provided batch of messages.
execute(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.SqsAcknowledgementExecutor
execute(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink: Send the provided Message instances to the TaskExecutor as a unit of work.
execute(Supplier<T>) - Method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters.AbstractThreadingComponentAdapter
execute(Message<T>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink: Send the provided Message to the TaskExecutor as a unit of work.
ExecutingAcknowledgementProcessor<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement: AcknowledgementProcessor specialization that allows for delegating acknowledgement execution to a AcknowledgementExecutor.
ExponentialBackoffErrorHandler<T> - Class in io.awspring.cloud.sqs.listener.errorhandler: An implementation of an Exponential Backoff error handler for asynchronous message processing.
ExponentialBackoffErrorHandler.Builder<T> - Class in io.awspring.cloud.sqs.listener.errorhandler

F

factory() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: The MessageListenerContainerFactory bean name to be used to process this endpoint.
factoryBeanName(String) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
factoryBeanName(String) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
FAIL - Enum constant in enum class io.awspring.cloud.sqs.listener.QueueNotFoundStrategy: Throw an exception and stop application startup if a queue is not found.
failed() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Batch: Returns the value of the failed record component.
Failed(String, String, Message<T>, Map<String, Object>) - Constructor for record class io.awspring.cloud.sqs.operations.SendResult.Failed: Creates an instance of a Failed record class.
failedFuture(Throwable) - Static method in class io.awspring.cloud.sqs.CompletableFutures: Create an exceptionally completed CompletableFuture.
FanOutMessageSink<T> - Class in io.awspring.cloud.sqs.listener.sink: MessageProcessingPipelineSink implementation that executes messages from the provided batch in parallel.
FanOutMessageSink() - Constructor for class io.awspring.cloud.sqs.listener.sink.FanOutMessageSink
fifoBatchGroupingStrategy(FifoBatchGroupingStrategy) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
fifoBatchGroupingStrategy(FifoBatchGroupingStrategy) - Method in interface io.awspring.cloud.sqs.listener.SqsContainerOptionsBuilder: Set how the messages from FIFO queues should be grouped when container listener mode is ListenerMode.BATCH.
FifoBatchGroupingStrategy - Enum Class in io.awspring.cloud.sqs.listener: Grouping strategy for Fifo SQS with batch listener mode.
FifoSqsComponentFactory<T> - Class in io.awspring.cloud.sqs.listener: ContainerComponentFactory implementation for creating components for FIFO queues.
FifoSqsComponentFactory() - Constructor for class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
FifoSqsMessageSource<T> - Class in io.awspring.cloud.sqs.listener.source: AbstractSqsMessageSource implementation for FIFO queues.
FifoSqsMessageSource() - Constructor for class io.awspring.cloud.sqs.listener.source.FifoSqsMessageSource
FifoUtils - Class in io.awspring.cloud.sqs: Methods related to FIFO queues.
findHandlerForPayload(Class<?>) - Method in class io.awspring.cloud.sqs.listener.adapter.CompositeInvocableHandler: Finds the appropriate handler method for the given payload type.
first(Function<MessageProcessingConfiguration<T>, MessageProcessingPipeline<T>>) - Static method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder
FIXED_HIGH_THROUGHPUT - Enum constant in enum class io.awspring.cloud.sqs.listener.BackPressureMode: Set fixed high throughput mode.
fromBuilder(B) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Copy the given builder settings to this builder.
fromBuilder(SqsContainerOptionsBuilder) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
fromHeaders(MessageHeaders) - Method in interface io.awspring.cloud.sqs.support.converter.HeaderMapper: Map the provided MessageHeaders into the returning message type.
fromHeaders(MessageHeaders) - Method in class io.awspring.cloud.sqs.support.converter.SqsHeaderMapper
fromMessage(Message<?>, Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsMessageConverter: Deprecated.
fromMessage(Message<?>, Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsNotificationConverter: Deprecated.
fromMessage(Message<?>, Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsSubjectConverter: Deprecated.
fromMessage(Message<?>, Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.SnsMessageConverter
fromMessage(Message<?>, Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.SnsNotificationConverter
fromMessage(Message<?>, Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.SnsSubjectConverter
fromMessage(Message<?>, Class<?>, Object) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsMessageConverter: Deprecated.
fromMessage(Message<?>, Class<?>, Object) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsNotificationConverter: Deprecated.
fromMessage(Message<?>, Class<?>, Object) - Method in class io.awspring.cloud.sqs.support.converter.SnsMessageConverter
fromMessage(Message<?>, Class<?>, Object) - Method in class io.awspring.cloud.sqs.support.converter.SnsNotificationConverter
fromMessagingMessage(Message<?>) - Method in interface io.awspring.cloud.sqs.support.converter.ContextAwareMessagingMessageConverter
fromMessagingMessage(Message<?>) - Method in interface io.awspring.cloud.sqs.support.converter.MessagingMessageConverter: Convert a Message to a message from a specific messaging system.
fromMessagingMessage(Message<?>, MessageConversionContext) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter
fromMessagingMessage(Message<?>, MessageConversionContext) - Method in interface io.awspring.cloud.sqs.support.converter.ContextAwareMessagingMessageConverter: Convert a Message to a message from a specific messaging system.
FULL - Static variable in interface io.awspring.cloud.sqs.listener.errorhandler.Jitter: Full jitter strategy - returns a random value between 0 and the original timeout.
fullBatchBackPressureHandler() - Static method in class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactories: Creates a new FullBatchBackPressureHandler using the provided ContainerOptions.
FullBatchBackPressureHandler - Class in io.awspring.cloud.sqs.listener.backpressure: Non-blocking BackPressureHandler implementation that ensures the exact batch size is requested.
FullBatchBackPressureHandler.Builder - Class in io.awspring.cloud.sqs.listener.backpressure

G

get() - Static method in class io.awspring.cloud.sqs.LifecycleHandler: Get the singleton instance for this class.
getAckHandler() - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration
getAcknowledgementCallback() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
getAcknowledgementCallback() - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementProcessor: Retrieve an acknowledgement callback that can be used to offer messages to be acknowledged by this processor.
getAcknowledgementCallback() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
getAcknowledgementCallback() - Method in interface io.awspring.cloud.sqs.support.converter.AcknowledgementAwareMessageConversionContext
getAcknowledgementCallback() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
getAcknowledgementInterval() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getAcknowledgementInterval() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the maximum interval between acknowledgements for batch acknowledgements.
getAcknowledgementMode() - Method in class io.awspring.cloud.sqs.config.SqsEndpoint: Returns the acknowledgement mode configured for this endpoint.
getAcknowledgementMode() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getAcknowledgementMode() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the AcknowledgementMode for this container.
getAcknowledgementOrdering() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getAcknowledgementOrdering() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the AcknowledgementOrdering for this container.
getAcknowledgementResultCallback() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Return the AcknowledgementResultCallback instance used by this container.
getAcknowledgementResultTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getAcknowledgementResultTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
getAcknowledgementResultTaskExecutor() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the TaskExecutor to be used by blocking AcknowledgementResultCallback implementations for this container.
getAcknowledgementShutdownTimeout() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getAcknowledgementShutdownTimeout() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the maximum amount of time that the container should wait for batched acknowledgements to finish before shutting down.
getAcknowledgementThreshold() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getAcknowledgementThreshold() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the threshold for triggering a batch acknowledgement.
getAcknowledgmentCallback() - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext
getAcknowledgmentProcessor() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
getAnnotationClass() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getAnnotationClass() - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
getBackPressureHandlerFactory() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getBackPressureHandlerFactory() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the BackPressureHandlerFactory to create a BackPressureHandler for this container.
getBackPressureMode() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getBackPressureMode() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the BackPressureMode for this container.
getBatchSize() - Method in interface io.awspring.cloud.sqs.listener.backpressure.BatchAwareBackPressureHandler: Deprecated.
This method is deprecated and will not be used by the Spring Cloud AWS SQS listener anymore.
getBatchSize() - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
getBean() - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Get the bean instance to be used when handling a message for this endpoint.
getBeanFactory() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getComponentsTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getComponentsTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer
getComponentsTaskExecutor() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the TaskExecutor to be used by this container's components.
getComponentType() - Method in class io.awspring.cloud.sqs.integration.SqsMessageDrivenChannelAdapter
getConfigurableBeanFactory() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getContainerById(String) - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
getContainerById(String) - Method in interface io.awspring.cloud.sqs.listener.MessageListenerContainerRegistry: Return the MessageListenerContainer instance registered within this registry with the provided id, or null if none.
getContainerComponentFactories() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Return the ContainerComponentFactory instances to be used for creating this container's components.
getContainerOptions() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
getContextualName(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getContextualName(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getCustomHighCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention: Return custom high cardinality key values for the observation.
getCustomHighCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention: Return custom high cardinality key values for the observation.
getCustomLowCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention: Return custom low cardinality key values for the observation.
getCustomLowCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention: Return custom low cardinality key values for the observation.
getDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation
getDefaultConvention() - Method in interface io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Specifics: Return the default ObservationConvention for the specific messaging system.
getDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation
getDefaultConvention() - Method in interface io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Specifics: Return the default ObservationConvention for the specific messaging system.
getDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.SqsSpecifics
getDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.SqsSpecifics
getDefaultHandlerMethod(Class<?>, List<Method>) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getDefaultHandlerMethod(Class<?>, List<Method>) - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
getDelegate() - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
getDestinationName() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Context: Return the destination name.
getDocumentation() - Method in interface io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Specifics: Return the ObservationDocumentation for the specific messaging system.
getDocumentation() - Method in interface io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Specifics: Return the ObservationDocumentation for the specific messaging system.
getDocumentation() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.SqsSpecifics
getDocumentation() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.SqsSpecifics
getEndpoint() - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint
getEndpoint() - Method in exception io.awspring.cloud.sqs.operations.MessagingOperationFailedException: Get the endpoint which the operation failed.
getEndpointId(String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getErrorHandler() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Return the AsyncErrorHandler instance used by this container.
getErrorHandler() - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration
getExpressionResolver() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getFailedAcknowledgementMessages() - Method in exception io.awspring.cloud.sqs.SqsAcknowledgementException: Return the messages that failed to be acknowledged.
getFailedMessage() - Method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException: Return the message which listener execution failed.
getFailedMessage() - Method in exception io.awspring.cloud.sqs.operations.MessagingOperationFailedException: A single failed message, if present.
getFailedMessages() - Method in exception io.awspring.cloud.sqs.listener.InterceptorExecutionFailedException
getFailedMessages() - Method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException: Return the messages which listener execution failed.
getFailedMessages() - Method in interface io.awspring.cloud.sqs.listener.MessageProcessingException: Return the messages for which processing failed.
getFailedMessages() - Method in exception io.awspring.cloud.sqs.operations.MessagingOperationFailedException: The failed messages.
getFifoBatchGroupingStrategy() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions: Get messages grouping strategy in FIFO queues when retrieved by the container in listener mode ListenerMode.BATCH.
getGeneratedIdPrefix() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getGeneratedIdPrefix() - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
getHandlerMethods(Class<?>) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getHandlerMethods(Class<?>) - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
getHeader(Collection<Message>, String, Class<T>) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Get the specified header or throw an exception if such header is not present.
getHeader(Message<?>, String, Class<T>) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Get the specified header or throw an exception if such header is not present.
getHeaderAsString(Message<?>, String) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Get the provided header as String or throw if not present.
getHighCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation
getHighCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation
getHighCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getHighCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getId() - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint
getId() - Method in interface io.awspring.cloud.sqs.config.Endpoint: An optional id for this endpoint.
getId() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
getId() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
getId() - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler
getId() - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler
getId() - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler
getId() - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
getId() - Method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler
getId() - Method in interface io.awspring.cloud.sqs.listener.IdentifiableContainerComponent: Get the component id.
getId() - Method in interface io.awspring.cloud.sqs.listener.MessageListenerContainer: Get the container id.
getId() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
getId(Collection<Message<T>>) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Return the messages' ID as a concatenated {@link String].
getId(Message<?>) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Return the message's ID as {@link String].
getInterceptors() - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext
getInterceptors(MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AbstractBeforeProcessingInterceptorExecutionStage
getInterceptors(MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.BeforeProcessingContextInterceptorExecutionStage
getInterceptors(MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.BeforeProcessingInterceptorExecutionStage
getJacksonMessageConverterMigration() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Get the object mapper used to deserialize payloads.
getJsonMapper() - Method in class io.awspring.cloud.sqs.support.converter.legacy.JacksonJsonMessageConverterMigration: Deprecated.
getListenerContainerFactoryName() - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint
getListenerContainerFactoryName() - Method in interface io.awspring.cloud.sqs.config.Endpoint: The name of the factory bean that will process this endpoint.
getListenerContainers() - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
getListenerContainers() - Method in interface io.awspring.cloud.sqs.listener.MessageListenerContainerRegistry: Return the MessageListenerContainer instances registered within this registry.
getListenerMode() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getListenerMode() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the ListenerMode mode for this container.
getListenerShutdownTimeout() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getListenerShutdownTimeout() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the maximum amount of time that the container should wait for processing tasks to finish before shutting down.
getLogicalNames() - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint
getLogicalNames() - Method in interface io.awspring.cloud.sqs.config.Endpoint: The logical names for this endpoint.
getLowCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation
getLowCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation
getLowCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getLowCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getMaxConcurrentMessages() - Method in class io.awspring.cloud.sqs.config.SqsEndpoint: Set the maximum concurrent messages that can be processed simultaneously for each queue.
getMaxConcurrentMessages() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getMaxConcurrentMessages() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Set the maximum concurrent messages that can be processed simultaneously for each queue.
getMaxDelayBetweenPolls() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getMaxDelayBetweenPolls() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Sets the maximum time the polling thread should wait for a full batch of permits to be available before trying to acquire a partial batch if so configured.
getMaxMessagesPerPoll() - Method in class io.awspring.cloud.sqs.config.SqsEndpoint: Return the maximum amount of messages that should be returned in a poll.
getMaxMessagesPerPoll() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getMaxMessagesPerPoll() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the number of messages that should be returned per poll.
getMessage() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the message payload.
getMessage() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Context: Return the message.
getMessage() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Context: Return the message.
getMessageAsString() - Method in class io.awspring.cloud.sqs.support.converter.AbstractSnsJsonNode
getMessageAsString() - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsJsonNode: Deprecated.
getMessageAsString() - Method in class io.awspring.cloud.sqs.support.converter.SnsJsonNode
getMessageAttributeNames() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions: Get the messageAttributeNames that will be retrieved and added as headers in messages.
getMessageAttributes() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the message attributes.
getMessageConversionContext() - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource
getMessageConverter() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getMessageConverter() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the MessagingMessageConverter for this container.
getMessageConverterConsumer() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Get the message converters list consumer.
getMessageDeduplicationId() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Context: Return the message deduplication id.
getMessageDeduplicationId() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Context: Return the message deduplication id.
getMessageGroupId() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Context: Return the message group id.
getMessageGroupId() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Context: Return the message group id.
getMessageGroupingFunction() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
getMessageHandlerMethodFactory() - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Get the MessageHandlerMethodFactory to be used for handling messages in this endpoint.
getMessageHandlerMethodFactory() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Return the MessageHandlerMethodFactory to be used to create MessageHandler instances for the Endpoints.
getMessageId() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the message ID.
getMessageId() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Context: Return the message id.
getMessageId() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Context: Return the message id.
getMessageInterceptors() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Return the AsyncMessageInterceptor instances used by this container.
getMessageInterceptors() - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration
getMessageInterceptors(MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AbstractAfterProcessingInterceptorExecutionStage
getMessageInterceptors(MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AfterProcessingContextInterceptorExecutionStage
getMessageInterceptors(MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AfterProcessingInterceptorExecutionStage
getMessageListener() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Return the AsyncMessageListener instance used by this container.
getMessageListener() - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration
getMessageListenerContainerRegistryBeanName() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
getMessageListenerContainerRegistryBeanName() - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
getMessageSystemAttributeNames() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions: Get the MessageSystemAttributeNames that will be retrieved and added as headers in messages.
getMessageVisibility() - Method in class io.awspring.cloud.sqs.config.SqsEndpoint: Return the message visibility for this endpoint.
getMessageVisibility() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions: Get the message visibility for messages retrieved by the container.
getMessagingSystem() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getMessagingSystem() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getMessagingSystem() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.DefaultConvention
getMessagingSystem() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.DefaultConvention
getMethodArgumentResolversConsumer() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Get the method argument resolvers list consumer.
getMethodPayloadTypeInferrer() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Get the MethodPayloadTypeInferrer used for inferring payload types from listener method signatures.
getMethods() - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint
getName() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getName() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getName() - Method in interface io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Convention: Return the name of this observation.
getName() - Method in interface io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Convention: Return the name of this observation.
getObjectMapper() - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2MessageConverterMigration: Deprecated.
getObservationConvention() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getObservationConvention() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return a custom ObservationConvention to use with this container.
getObservationRegistry() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getObservationRegistry() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the ObservationRegistry to use in this container.
getPayloadClass() - Method in interface io.awspring.cloud.sqs.support.converter.MessageConversionContext: An optional parameter with the payload class to be used by the conversion process.
getPayloadClass() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
getPayloadDeserializationType() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Return the target type for payload deserialization, or null if not set.
getPayloadMessageConverter() - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Get the MessageConverter to be used for converting the Message instances payloads.
getPayloadToDeserialize(S) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter
getPayloadToDeserialize(Message) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SqsMessagingMessageConverter: Deprecated.
getPayloadToDeserialize(Message) - Method in class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter
getPhase() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
getPhase() - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
getPollBackOffPolicy() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getPollBackOffPolicy() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the BackOffPolicy to be applied when polling throws an exception.
getPollingEndpointName() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
getPollTimeout() - Method in class io.awspring.cloud.sqs.config.SqsEndpoint: The maximum duration to wait for messages in a given poll.
getPollTimeout() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
getPollTimeout() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Return the timeout for polling messages for this endpoint.
getQueue() - Method in exception io.awspring.cloud.sqs.SqsAcknowledgementException: Return the queue from which the messages were received from.
getQueueAttribute(QueueAttributeName) - Method in class io.awspring.cloud.sqs.listener.QueueAttributes: Return a specific attribute for this queue, if present.
getQueueAttributeNames() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions: Get the QueueAttributeNames that will be retrieved from the queue and added as headers to the messages.
getQueueAttributes() - Method in class io.awspring.cloud.sqs.listener.QueueAttributes: Return the attributes for this queue.
getQueueAttributes() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
getQueueName() - Method in class io.awspring.cloud.sqs.listener.QueueAttributes: Return the queue name.
getQueueNames() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Return the queue names assigned to this container.
getQueueNotFoundStrategy() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions: Get the QueueNotFoundStrategy for the container.
getQueues() - Method in class io.awspring.cloud.sqs.integration.SqsMessageDrivenChannelAdapter
getQueueUrl() - Method in class io.awspring.cloud.sqs.listener.QueueAttributes: Return the queue url.
getRandomSupplier() - Method in class io.awspring.cloud.sqs.listener.errorhandler.Jitter.Context
getReceiveMessageConversionContext(String, Class<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
getReceiveMessageConversionContext(String, Class<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
getReceiveMessageCount(Message<T>) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
getSendBatchResult() - Method in exception io.awspring.cloud.sqs.operations.SendBatchOperationFailedException: Get the detailed result of the batch send attempt.
getSendBatchResult(Class<T>) - Method in exception io.awspring.cloud.sqs.operations.SendBatchOperationFailedException: Get the detailed result of the batch send attempt, casting the result to the provided payload type.
getSendMessageConversionContext(Message<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
getSendResult() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Context: Return the send result.
getSequenceNumber() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the sequence number.
getSignature() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the signature.
getSignatureVersion() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the signature version.
getSigningCertURL() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the signing certificate URL.
getSourceKind() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getSourceKind() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getSourceKind() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.DefaultConvention
getSourceKind() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.DefaultConvention
getSourceName() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Context: Return the source name.
getSpecificDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation
getSpecificDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation
getSpecificDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Documentation
getSpecificDefaultConvention() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Documentation
getSpecificHighCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation
getSpecificHighCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation
getSpecificHighCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Documentation
getSpecificHighCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Documentation
getSpecificHighCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getSpecificHighCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getSpecificHighCardinalityKeyValues(SqsListenerObservation.Context) - Method in class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.DefaultConvention
getSpecificHighCardinalityKeyValues(SqsTemplateObservation.Context) - Method in class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.DefaultConvention
getSpecificLowCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation
getSpecificLowCardinalityKeyNames() - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation
getSpecificLowCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Convention
getSpecificLowCardinalityKeyValues(ContextType) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Convention
getSqsAsyncClient() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
getSqsAsyncClientInstance() - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory
getSubject() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the subject.
getSubjectAsString() - Method in class io.awspring.cloud.sqs.support.converter.AbstractSnsJsonNode
getSubjectAsString() - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsJsonNode: Deprecated.
getSubjectAsString() - Method in class io.awspring.cloud.sqs.support.converter.SnsJsonNode
getSuccessfullyAcknowledgedMessages() - Method in exception io.awspring.cloud.sqs.SqsAcknowledgementException: Return the messages that were successfully acknowledged.
getTimeout() - Method in class io.awspring.cloud.sqs.listener.errorhandler.Jitter.Context
getTimestamp() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the timestamp.
getTopicArn() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the topic ARN.
getType() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the notification type.
getType() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification.MessageAttribute: Gets the attribute type.
getUnsubscribeUrl() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification: Gets the unsubscribe URL.
getValidator() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Return the Validator instance used for payload validating in HandlerMethodArgumentResolver instances.
getValue() - Method in class io.awspring.cloud.sqs.support.converter.SnsNotification.MessageAttribute: Gets the attribute value.
getVisibility(Collection<Message<T>>) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
getVisibility(Message<T>) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper
groupMessagesByReceiveMessageCount(Collection<Message<T>>) - Static method in class io.awspring.cloud.sqs.listener.errorhandler.ErrorHandlerVisibilityHelper

H

HALF - Static variable in interface io.awspring.cloud.sqs.listener.errorhandler.Jitter: Half jitter strategy - returns a value uniformly between ceil(timeout/2) and timeout.
handle(Collection<Message<T>>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.errorhandler.AsyncErrorHandler: Asynchronously handle the errors thrown processing the given Message instances.
handle(Collection<Message<T>>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.errorhandler.ErrorHandler: Handle errors thrown when processing a batch of Messages.
handle(Collection<Message<T>>, Throwable) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler
handle(Collection<Message<T>>, Throwable) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ImmediateRetryAsyncErrorHandler
handle(Collection<Message<T>>, Throwable) - Method in class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler
handle(Message<T>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.errorhandler.AsyncErrorHandler: Asynchronously handle the errors thrown processing the given Message.
handle(Message<T>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.errorhandler.ErrorHandler: Handle errors thrown when processing a Message.
handle(Message<T>, Throwable) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler
handle(Message<T>, Throwable) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ImmediateRetryAsyncErrorHandler
handle(Message<T>, Throwable) - Method in class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler
handleAdditionalHeaders(Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
handleAdditionalHeaders(Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
handleCompose(CompletableFuture<T>, BiFunction<? super T, Throwable, ? extends CompletableFuture>) - Static method in class io.awspring.cloud.sqs.CompletableFutures: Compose the provided future with a function to handle the result, taking a value, a throwable and providing a completable future as a result.
handleMessageInternal(Message<?>) - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
HandlerMethodEndpoint - Interface in io.awspring.cloud.sqs.config: Endpoint specialization that indicates that Message instances coming from this endpoint will be handled by a HandlerMethod.
hashCode() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Batch: Returns a hash code value for this object.
hashCode() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Failed: Returns a hash code value for this object.
hashCode() - Method in record class io.awspring.cloud.sqs.operations.SendResult: Returns a hash code value for this object.
hasListenerException(Throwable) - Static method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException: Deprecated.
use MessageProcessingException.hasProcessingException(Throwable) instead.
hasProcessingException(Throwable) - Static method in interface io.awspring.cloud.sqs.listener.MessageProcessingException: Check whether a MessageProcessingException is present anywhere in the cause chain of t.
header(String, Object) - Method in interface io.awspring.cloud.sqs.operations.SqsSendOptions: Add a header to be sent in the message.
HeaderMapper<S> - Interface in io.awspring.cloud.sqs.support.converter: Mapper interface to map from and to MessageHeaders and a given source type.
headers(Map<String, Object>) - Method in interface io.awspring.cloud.sqs.operations.SqsSendOptions: Add headers to be sent in the message.

I

id() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: An id for the MessageListenerContainer that will be created to handle this endpoint.
id(String) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
id(String) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
id(String) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
IdentifiableContainerComponent - Interface in io.awspring.cloud.sqs.listener: Representation of a component that can be assigned an id.
ImmediateAcknowledgementProcessor<T> - Class in io.awspring.cloud.sqs.listener.acknowledgement
ImmediateAcknowledgementProcessor() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.ImmediateAcknowledgementProcessor
ImmediateRetryAsyncErrorHandler<T> - Class in io.awspring.cloud.sqs.listener.errorhandler: A default error handler implementation for asynchronous message processing.
ImmediateRetryAsyncErrorHandler() - Constructor for class io.awspring.cloud.sqs.listener.errorhandler.ImmediateRetryAsyncErrorHandler
increment(int) - Method in class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler.Builder
inferPayloadType(Method, List<HandlerMethodArgumentResolver>) - Method in interface io.awspring.cloud.sqs.config.MethodPayloadTypeInferrer: Infer the payload class from the given method and its argument resolvers.
inferPayloadType(Method, List<HandlerMethodArgumentResolver>) - Method in class io.awspring.cloud.sqs.config.DefaultMethodPayloadTypeInferrer
initializeHandlerMethodFactory() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
initialVisibilityTimeoutSeconds(int) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler.Builder
initialVisibilityTimeoutSeconds(int) - Method in class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler.Builder
INSTANCE - Static variable in class io.awspring.cloud.sqs.ConfigUtils
intercept(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.interceptor.AsyncMessageInterceptor: Perform an action on the messages or return different ones before processing.
intercept(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.interceptor.MessageInterceptor: Perform an action on the messages or return a different ones before processing.
intercept(Message<T>) - Method in interface io.awspring.cloud.sqs.listener.interceptor.AsyncMessageInterceptor: Perform an action on the message or return a different one before processing.
intercept(Message<T>) - Method in interface io.awspring.cloud.sqs.listener.interceptor.MessageInterceptor: Perform an action on the message or return a different one before processing.
InterceptorExecutionFailedException - Exception in io.awspring.cloud.sqs.listener: Exception thrown when a MessageInterceptor throws during before-processing execution.
InterceptorExecutionFailedException(String, Throwable, Collection<Message<T>>) - Constructor for exception io.awspring.cloud.sqs.listener.InterceptorExecutionFailedException
InterceptorExecutionFailedException(String, Throwable, Message<?>) - Constructor for exception io.awspring.cloud.sqs.listener.InterceptorExecutionFailedException
interceptors(Collection<AsyncMessageInterceptor<T>>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder
invoke(Message<?>) - Method in class io.awspring.cloud.sqs.listener.adapter.CompositeInvocableHandler: Invoke the appropriate handler for the given message.
invokeHandler(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.adapter.AbstractMethodInvokingListenerAdapter: Invokes the handler for the provided messages.
invokeHandler(Message<T>) - Method in class io.awspring.cloud.sqs.listener.adapter.AbstractMethodInvokingListenerAdapter: Invokes the handler for the provided message.
io.awspring.cloud.sqs - package io.awspring.cloud.sqs: SQS integration for Spring Cloud AWS.
io.awspring.cloud.sqs.annotation - package io.awspring.cloud.sqs.annotation: SqsListener annotation and classes to process it.
io.awspring.cloud.sqs.config - package io.awspring.cloud.sqs.config: Assembly-time components for SQS.
io.awspring.cloud.sqs.config.legacy - package io.awspring.cloud.sqs.config.legacy
io.awspring.cloud.sqs.integration - package io.awspring.cloud.sqs.integration
io.awspring.cloud.sqs.listener - package io.awspring.cloud.sqs.listener: Components for executing the flow of messages to and from a message listener.
io.awspring.cloud.sqs.listener.acknowledgement - package io.awspring.cloud.sqs.listener.acknowledgement: Components to process message acknowledgements.
io.awspring.cloud.sqs.listener.acknowledgement.handler - package io.awspring.cloud.sqs.listener.acknowledgement.handler: Strategies for handling acknowledgements after successful and / or failed message processing.
io.awspring.cloud.sqs.listener.adapter - package io.awspring.cloud.sqs.listener.adapter: Adapters for invoking a message listener registered by a listener annotation.
io.awspring.cloud.sqs.listener.backpressure - package io.awspring.cloud.sqs.listener.backpressure
io.awspring.cloud.sqs.listener.errorhandler - package io.awspring.cloud.sqs.listener.errorhandler: Components for handling errors and potentially recovering messages.
io.awspring.cloud.sqs.listener.interceptor - package io.awspring.cloud.sqs.listener.interceptor: Components for intercepting messages before or after processing.
io.awspring.cloud.sqs.listener.pipeline - package io.awspring.cloud.sqs.listener.pipeline: Pipeline abstraction to process messages in a container.
io.awspring.cloud.sqs.listener.sink - package io.awspring.cloud.sqs.listener.sink: Components to handle the flow of messages from a Source to a Pipeline.
io.awspring.cloud.sqs.listener.sink.adapter - package io.awspring.cloud.sqs.listener.sink.adapter: Composable message sink adapters to add behavior to sinks via a decorator pattern.
io.awspring.cloud.sqs.listener.source - package io.awspring.cloud.sqs.listener.source: Components that provide message instances to be processed.
io.awspring.cloud.sqs.operations - package io.awspring.cloud.sqs.operations: Components for converting source messages to Spring messaging messages.
io.awspring.cloud.sqs.support - package io.awspring.cloud.sqs.support: Auto-configuration for Amazon SQS (Simple Queue Service) integrations.
io.awspring.cloud.sqs.support.converter - package io.awspring.cloud.sqs.support.converter: Components for converting source messages to Spring messaging messages.
io.awspring.cloud.sqs.support.converter.legacy - package io.awspring.cloud.sqs.support.converter.legacy
io.awspring.cloud.sqs.support.observation - package io.awspring.cloud.sqs.support.observation
io.awspring.cloud.sqs.support.resolver - package io.awspring.cloud.sqs.support.resolver: Components for resolving method arguments in listener methods.
io.awspring.cloud.sqs.support.resolver.legacy - package io.awspring.cloud.sqs.support.resolver.legacy
isAutoStartup() - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions
isAutoStartup() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
isAutoStartup() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Checks whether the container should be started automatically or manually.
isDefault() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsHandler: Indicates whether this method should be used as the default fallback method if no other SqsHandler method matches the payload type.
isFifo(String) - Static method in class io.awspring.cloud.sqs.FifoUtils: Return whether the provided queue is Fifo.
isRunning() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
isRunning() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
isRunning() - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
isRunning() - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
isRunning() - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
isRunning() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
isRunning(Object) - Method in class io.awspring.cloud.sqs.LifecycleHandler: Check whether a object is running if it's an instance of SmartLifecycle.
isUsingDefaultPayloadTypeMapper() - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Check if this converter is using the default payload type mapper (header-based).

J

JACKSON_2 - Enum constant in enum class io.awspring.cloud.sqs.operations.SqsJacksonVersion: Deprecated.
JACKSON_3 - Enum constant in enum class io.awspring.cloud.sqs.operations.SqsJacksonVersion: Deprecated.
JacksonJsonMessageConverterMigration - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated, for removal: This API element is subject to removal in a future version.
JacksonJsonMessageConverterMigration(JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.JacksonJsonMessageConverterMigration: Deprecated.
JacksonMessageConverterMigration - Interface in io.awspring.cloud.sqs.support.converter.legacy: Deprecated, for removal: This API element is subject to removal in a future version.
jitter(Jitter) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler.Builder
Jitter - Interface in io.awspring.cloud.sqs.listener.errorhandler: Strategy interface for applying jitter to exponential backoff calculations.
Jitter.Context - Class in io.awspring.cloud.sqs.listener.errorhandler: Context for jitter calculations.

L

LegacyJackson2MessageConverterFactory - Class in io.awspring.cloud.sqs.config.legacy: Deprecated.
LegacyJackson2MessageConverterFactory() - Constructor for class io.awspring.cloud.sqs.config.legacy.LegacyJackson2MessageConverterFactory: Deprecated.
LegacyJackson2MessageConverterMigration - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated, for removal: This API element is subject to removal in a future version.
LegacyJackson2MessageConverterMigration(ObjectMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2MessageConverterMigration: Deprecated.
LegacyJackson2NotificationMessageArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver.legacy: Deprecated.
LegacyJackson2NotificationMessageArgumentResolver(MessageConverter, ObjectMapper) - Constructor for class io.awspring.cloud.sqs.support.resolver.legacy.LegacyJackson2NotificationMessageArgumentResolver: Deprecated.
LegacyJackson2NotificationSubjectArgumentResolver - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated.
LegacyJackson2NotificationSubjectArgumentResolver(ObjectMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2NotificationSubjectArgumentResolver: Deprecated.
LegacyJackson2SnsJsonNode - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated.
LegacyJackson2SnsJsonNode(ObjectMapper, String) - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsJsonNode: Deprecated.
LegacyJackson2SnsMessageConverter - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated.
LegacyJackson2SnsMessageConverter(MessageConverter, ObjectMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsMessageConverter: Deprecated.
LegacyJackson2SnsNotificationArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver.legacy: Deprecated.
LegacyJackson2SnsNotificationArgumentResolver(MessageConverter, ObjectMapper) - Constructor for class io.awspring.cloud.sqs.support.resolver.legacy.LegacyJackson2SnsNotificationArgumentResolver: Deprecated.

Creates a new resolver with the given converter and JSON mapper.
LegacyJackson2SnsNotificationConverter - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated.
LegacyJackson2SnsNotificationConverter(MessageConverter, ObjectMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsNotificationConverter: Deprecated.

Creates a new converter with the given payload converter and JSON mapper.
LegacyJackson2SnsSubjectConverter - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated.
LegacyJackson2SnsSubjectConverter(ObjectMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsSubjectConverter: Deprecated.
LegacyJackson2SqsMessagingMessageConverter - Class in io.awspring.cloud.sqs.support.converter.legacy: Deprecated.
LegacyJackson2SqsMessagingMessageConverter() - Constructor for class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SqsMessagingMessageConverter: Deprecated.
LifecycleHandler - Class in io.awspring.cloud.sqs: Handler for lifecycle methods.
LIMITED - Enum constant in enum class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler.ReleaseReason: All/Some permits were not used because another BackPressureHandler has a lower permits limit and the permits difference need to be aligned across all handlers.
LinearBackoffErrorHandler<T> - Class in io.awspring.cloud.sqs.listener.errorhandler: An implementation of a Linear Backoff error handler for asynchronous message processing.
LinearBackoffErrorHandler.Builder<T> - Class in io.awspring.cloud.sqs.listener.errorhandler
ListenerExecutionFailedException - Exception in io.awspring.cloud.sqs.listener: Exception thrown when the AsyncMessageListener completes with an exception.
ListenerExecutionFailedException(String, Throwable, Collection<Message<T>>) - Constructor for exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException
ListenerExecutionFailedException(String, Throwable, Message<?>) - Constructor for exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException
listenerMode(ListenerMode) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
listenerMode(ListenerMode) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the ListenerMode mode for this container.
ListenerMode - Enum Class in io.awspring.cloud.sqs.listener: Configure the delivery strategy to be used by a MessageListenerContainer.
listenerShutdownTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
listenerShutdownTimeout(Duration) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the maximum amount of time that the container should wait for tasks to finish before shutting down.
logError(Throwable, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
logError(Throwable, Message<T>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink

M

manageLifecycle(Consumer<SmartLifecycle>, Object...) - Method in class io.awspring.cloud.sqs.LifecycleHandler: Execute the provided action if the provided objects are SmartLifecycle instances.
manageMessageConverters(Consumer<List<MessageConverter>>) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Manage the list of MessageConverter instances to be used to convert payloads.
manageMethodArgumentResolvers(Consumer<List<HandlerMethodArgumentResolver>>) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Manage the list of HandlerMethodArgumentResolver instances to be used for resolving method arguments.
MANUAL - Enum constant in enum class io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode: Messages will not be acknowledged automatically by the container.
MANUAL - Enum constant in enum class io.awspring.cloud.sqs.operations.TemplateAcknowledgementMode: Don't acknowledge messages automatically.
MANUAL - Static variable in class io.awspring.cloud.sqs.annotation.SqsListenerAcknowledgementMode: Messages will not be acknowledged automatically by the container.
MAX_VISIBILITY_TIMEOUT_SECONDS - Static variable in interface io.awspring.cloud.sqs.listener.Visibility: The maximum visibility timeout interval, which corresponds to the maximum SQS visibility timeout of 12 hours.
maxConcurrentMessages() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: The maximum concurrent messages that can be processed simultaneously for each queue.
maxConcurrentMessages(int) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
maxConcurrentMessages(int) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the maximum concurrent messages that can be processed simultaneously for each queue.
maxConcurrentMessages(Integer) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
maxDelayBetweenPolls(Duration) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
maxDelayBetweenPolls(Duration) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the maximum time the polling thread should wait for a full batch of permits to be available before trying to acquire a partial batch if so configured.
maxMessagesPerPoll() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: The maximum number of messages to poll from SQS.
maxMessagesPerPoll(int) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
maxMessagesPerPoll(int) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the number of messages that should be returned per poll.
maxMessagesPerPoll(Integer) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
maxNumberOfMessages(Integer) - Method in interface io.awspring.cloud.sqs.operations.SqsReceiveOptions: Set the maximum number of messages to be returned.
maxVisibilityTimeoutSeconds(int) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler.Builder
maxVisibilityTimeoutSeconds(int) - Method in class io.awspring.cloud.sqs.listener.errorhandler.LinearBackoffErrorHandler.Builder
message() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Failed: Returns the value of the message record component.
message() - Method in record class io.awspring.cloud.sqs.operations.SendResult: Returns the value of the message record component.
MESSAGE_DEDUPLICATION_ID - Enum constant in enum class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Documentation.HighCardinalityTags: Message deduplication id for messages from FIFO queues.
MESSAGE_DEDUPLICATION_ID - Enum constant in enum class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Documentation.HighCardinalityTags: Message deduplication id for messages sent to FIFO queues.
MESSAGE_GROUP_ID - Enum constant in enum class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Documentation.HighCardinalityTags: Message group id for messages from FIFO queues.
MESSAGE_GROUP_ID - Enum constant in enum class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Documentation.HighCardinalityTags: Message group id for messages sent to FIFO queues.
MESSAGE_ID - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.HighCardinalityTags: Message id.
MESSAGE_ID - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.HighCardinalityTags: Message id.
MESSAGE_ID - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: Message ID header from an SQS send result.
MessageAttribute(String, String) - Constructor for class io.awspring.cloud.sqs.support.converter.SnsNotification.MessageAttribute: Creates a new message attribute.
MessageAttributeDataTypes - Class in io.awspring.cloud.sqs.support.converter
messageAttributeNames(Collection<String>) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
messageAttributeNames(Collection<String>) - Method in interface io.awspring.cloud.sqs.listener.SqsContainerOptionsBuilder: Set the messageAttributeNames that will be retrieved and added as headers in messages.
messageAttributeNames(Collection<String>) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateOptions: The message attributes to be retrieved with the message and added as headers to received messages.
MessageConversionContext - Interface in io.awspring.cloud.sqs.support.converter: Marker interface for a message conversion context.
messageConverter(MessagingMessageConverter<?>) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
messageConverter(MessagingMessageConverter<?>) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the MessagingMessageConverter for this container.
messageConverter(MessagingMessageConverter<Message>) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Set the MessagingMessageConverter to be used by the template.
MessageConverterFactory - Class in io.awspring.cloud.sqs.config: Factory util class to construct MessageConverter Jackson 3 specific.
MessageConverterFactory() - Constructor for class io.awspring.cloud.sqs.config.MessageConverterFactory
messageDeduplicationId(String) - Method in interface io.awspring.cloud.sqs.operations.SqsSendOptions: Set the messageDeduplicationId for the message.
MessageExecutionThread - Class in io.awspring.cloud.sqs: A Thread implementation for processing messages.
MessageExecutionThread() - Constructor for class io.awspring.cloud.sqs.MessageExecutionThread: Create an instance.
MessageExecutionThread(ThreadGroup, Runnable, String) - Constructor for class io.awspring.cloud.sqs.MessageExecutionThread: Create an instance with the provided arguments.
MessageExecutionThreadFactory - Class in io.awspring.cloud.sqs: CustomizableThreadFactory implementation for creating MessageExecutionThread instances.
MessageExecutionThreadFactory() - Constructor for class io.awspring.cloud.sqs.MessageExecutionThreadFactory: Create a new MessageExecutionThreadFactory with default thread name prefix.
MessageExecutionThreadFactory(String) - Constructor for class io.awspring.cloud.sqs.MessageExecutionThreadFactory: Create a new MessageExecutionThreadFactory with the given thread name prefix.
messageGroupId(String) - Method in interface io.awspring.cloud.sqs.operations.SqsSendOptions: Set the messageGroupId for the message.
MessageGroupingSinkAdapter<T> - Class in io.awspring.cloud.sqs.listener.sink.adapter: AbstractDelegatingMessageListeningSinkAdapter implementation that groups the received batch according to the provided grouping function and emits each sub batch to the delegate separately.
MessageGroupingSinkAdapter(MessageSink<T>, Function<Message<T>, String>) - Constructor for class io.awspring.cloud.sqs.listener.sink.adapter.MessageGroupingSinkAdapter
MessageHeaderContextAccessor - Class in io.awspring.cloud.sqs.support.observation: ContextAccessor that use MessageHeaders to hold the Observation context.
MessageHeaderContextAccessor() - Constructor for class io.awspring.cloud.sqs.support.observation.MessageHeaderContextAccessor
MessageHeaderUtils - Class in io.awspring.cloud.sqs: Utility class for extracting MessageHeaders from a Message.
messageId() - Method in record class io.awspring.cloud.sqs.operations.SendResult: Returns the value of the messageId record component.
messageInterceptor(AsyncMessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
messageInterceptor(AsyncMessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
messageInterceptor(MessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
messageInterceptor(MessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
MessageInterceptor<T> - Interface in io.awspring.cloud.sqs.listener.interceptor: Interface for intercepting messages before and after execution.
messageListener(AsyncMessageListener<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder
messageListener(MessageListener<T>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder
messageListener(MessageListener<T>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
MessageListener<T> - Interface in io.awspring.cloud.sqs.listener: Interface to process incoming Messages.
MessageListenerContainer<T> - Interface in io.awspring.cloud.sqs.listener: A container for an AsyncMessageListener with SmartLifecycle capabilities.
MessageListenerContainerFactory<C extends MessageListenerContainer<?>> - Interface in io.awspring.cloud.sqs.config: Creates MessageListenerContainer instances for given Endpoint instances or endpoint names.
MessageListenerContainerRegistry - Interface in io.awspring.cloud.sqs.listener: Interface for registering and looking up containers at startup and runtime.
MessageListenerExecutionStage<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Stage responsible for executing the AsyncMessageListener.
MessageListenerExecutionStage(MessageProcessingConfiguration<T>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.MessageListenerExecutionStage
MessageProcessingConfiguration<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Holds the components that will be used on the MessageProcessingPipeline.
MessageProcessingConfiguration.Builder<T> - Class in io.awspring.cloud.sqs.listener.pipeline
MessageProcessingContext<T> - Class in io.awspring.cloud.sqs.listener: A message processing context that can be used for communication between components.
MessageProcessingException - Interface in io.awspring.cloud.sqs.listener: Implemented by exceptions that carry references to the Message instances that failed during processing.
MessageProcessingPipeline<T> - Interface in io.awspring.cloud.sqs.listener.pipeline: Represents a stage in the processing pipeline that will be used to process Message instances.
MessageProcessingPipelineBuilder<T> - Class in io.awspring.cloud.sqs.listener.pipeline: Entrypoint for constructing a MessageProcessingPipeline MessageProcessingPipelineBuilder.ComposingMessagePipelineStage.
MessageProcessingPipelineBuilder(Function<MessageProcessingConfiguration<T>, MessageProcessingPipeline<T>>) - Constructor for class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder
MessageProcessingPipelineSink<T> - Interface in io.awspring.cloud.sqs.listener.sink: MessageSink specialization that uses a MessageProcessingPipeline as the output.
MessageSink<T> - Interface in io.awspring.cloud.sqs.listener.sink: Component that handles the flow of Messages.
MessageSource<T> - Interface in io.awspring.cloud.sqs.listener.source: A source of Message instances.
messageSystemAttributeNames(Collection<MessageSystemAttributeName>) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
messageSystemAttributeNames(Collection<MessageSystemAttributeName>) - Method in interface io.awspring.cloud.sqs.listener.SqsContainerOptionsBuilder: Set the MessageSystemAttributeNames that will be retrieved and added as headers in messages.
messageSystemAttributeNames(Collection<MessageSystemAttributeName>) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateOptions: The message system attributes to be retrieved with the message and added as headers to received messages.
messageVisibility(Integer) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
messageVisibility(Duration) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
messageVisibility(Duration) - Method in interface io.awspring.cloud.sqs.listener.SqsContainerOptionsBuilder: Set the message visibility for messages retrieved by the container.
MessageVisibilityExtendingSinkAdapter<T> - Class in io.awspring.cloud.sqs.listener.sink.adapter: An AbstractDelegatingMessageListeningSinkAdapter that adds an MessageVisibilityExtendingSinkAdapter<T>.io.awspring.cloud.sqs.listener.sink.adapter.MessageVisibilityExtendingSinkAdapter.OriginalBatchMessageVisibilityExtendingInterceptor to the MessageProcessingContext.
MessageVisibilityExtendingSinkAdapter(MessageSink<T>) - Constructor for class io.awspring.cloud.sqs.listener.sink.adapter.MessageVisibilityExtendingSinkAdapter
messageVisibilitySeconds() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: The message visibility to be applied to messages received from the provided queues.
MESSAGING_DESTINATION_KIND - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.LowCardinalityTags: Messaging destination kind.
MESSAGING_DESTINATION_NAME - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.LowCardinalityTags: Messaging destination name.
MESSAGING_OPERATION - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.LowCardinalityTags: Messaging operation.
MESSAGING_OPERATION - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.LowCardinalityTags: Messaging operation.
MESSAGING_SOURCE_KIND - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.LowCardinalityTags: Messaging source kind.
MESSAGING_SOURCE_NAME - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.LowCardinalityTags: Messaging source name.
MESSAGING_SYSTEM - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.LowCardinalityTags: Messaging system.
MESSAGING_SYSTEM - Enum constant in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.LowCardinalityTags: Messaging system.
MessagingHeaders - Class in io.awspring.cloud.sqs: MessageHeaders associated with messaging operations.
MessagingHeaders() - Constructor for class io.awspring.cloud.sqs.MessagingHeaders
MessagingMessageConverter<S> - Interface in io.awspring.cloud.sqs.support.converter: A converter for converting source or target objects to and from Spring Messaging Messages.
MessagingMessageHeaders - Class in io.awspring.cloud.sqs.support.converter: MessageHeaders implementation that allows providing an external UUID.
MessagingMessageHeaders(Map<String, Object>) - Constructor for class io.awspring.cloud.sqs.support.converter.MessagingMessageHeaders: Create an instance with the provided headers.
MessagingMessageHeaders(Map<String, Object>, UUID) - Constructor for class io.awspring.cloud.sqs.support.converter.MessagingMessageHeaders: Create an instance with the provided headers and id.
MessagingMessageHeaders(Map<String, Object>, UUID, Long) - Constructor for class io.awspring.cloud.sqs.support.converter.MessagingMessageHeaders: Create an instance with the provided arguments.
MessagingMessageListenerAdapter<T> - Class in io.awspring.cloud.sqs.listener.adapter: MessageListener implementation to handle a message by invoking a method handler.
MessagingMessageListenerAdapter(CompositeInvocableHandler) - Constructor for class io.awspring.cloud.sqs.listener.adapter.MessagingMessageListenerAdapter
MessagingMessageListenerAdapter(InvocableHandlerMethod) - Constructor for class io.awspring.cloud.sqs.listener.adapter.MessagingMessageListenerAdapter
MessagingOperationFailedException - Exception in io.awspring.cloud.sqs.operations: Exception to represent the failure of a Messaging Operation.
MessagingOperationFailedException(String, String) - Constructor for exception io.awspring.cloud.sqs.operations.MessagingOperationFailedException: Create an instance with the provided error message.
MessagingOperationFailedException(String, String, Throwable) - Constructor for exception io.awspring.cloud.sqs.operations.MessagingOperationFailedException: Create an instance with the provided error message and cause, if any.
MessagingOperationFailedException(String, String, Collection<Message<T>>, Throwable) - Constructor for exception io.awspring.cloud.sqs.operations.MessagingOperationFailedException: Create an instance with the provided parameters and a batch of messages.
MessagingOperationFailedException(String, String, Message<?>, Throwable) - Constructor for exception io.awspring.cloud.sqs.operations.MessagingOperationFailedException: Create an instance with the provided parameters and a single message.
MessagingOperations - Interface in io.awspring.cloud.sqs.operations: Synchronous messaging operations.
MessagingTemplateOptions<O extends MessagingTemplateOptions<O>> - Interface in io.awspring.cloud.sqs.operations: Options to be used by the template.
MethodPayloadTypeInferrer - Interface in io.awspring.cloud.sqs.config: Strategy interface for inferring the payload type from a listener method signature.
methods(List<Method>) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
MultiMethodSqsEndpoint - Class in io.awspring.cloud.sqs.config: A SqsEndpoint extension that supports multiple handler methods annotated with SqsHandler
MultiMethodSqsEndpoint(MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder) - Constructor for class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint
MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder - Class in io.awspring.cloud.sqs.config
MultiMethodSqsEndpointBuilder() - Constructor for class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
multiplier(double) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler.Builder

N

NeverAcknowledgementHandler<T> - Class in io.awspring.cloud.sqs.listener.acknowledgement.handler: AcknowledgementHandler implementation that never acknowledges regardless of the result.
NeverAcknowledgementHandler() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.handler.NeverAcknowledgementHandler
newAsyncTemplate(SqsAsyncClient) - Static method in class io.awspring.cloud.sqs.operations.SqsTemplate: Create a new SqsTemplate instance with the provided SqsAsyncClient, only exposing the async methods contained in SqsAsyncOperations.
newSyncTemplate(SqsAsyncClient) - Static method in class io.awspring.cloud.sqs.operations.SqsTemplate: Create a new SqsTemplate instance with the provided SqsAsyncClient, only exposing the sync methods contained in SqsOperations.
newTemplate(SqsAsyncClient) - Static method in class io.awspring.cloud.sqs.operations.SqsTemplate: Create a new SqsTemplate instance with the provided SqsAsyncClient and both sync and async operations.
NONE - Static variable in interface io.awspring.cloud.sqs.listener.errorhandler.Jitter: No jitter strategy - returns the original timeout value.
NONE_FETCHED - Enum constant in enum class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler.ReleaseReason: No messages were retrieved from SQS, so all permits need to be returned.
noPermitsReturnedWaitTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler.Builder
NotificationMessageArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver
NotificationMessageArgumentResolver(MessageConverter, JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.resolver.NotificationMessageArgumentResolver
NotificationSubjectArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver
NotificationSubjectArgumentResolver(JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.resolver.NotificationSubjectArgumentResolver
NUMBER - Static variable in class io.awspring.cloud.sqs.support.converter.MessageAttributeDataTypes: Number message attribute data type.

O

ObservableComponent - Interface in io.awspring.cloud.sqs.listener: Represents a AbstractPipelineMessageListenerContainer component that can be observed.
observationConvention(SqsListenerObservation.Convention) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
observationConvention(SqsListenerObservation.Convention) - Method in interface io.awspring.cloud.sqs.listener.SqsContainerOptionsBuilder: Set a custom SqsListenerObservation.Convention to be used in this container.
observationConvention(SqsTemplateObservation.Convention) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateOptions: Set a custom ObservationConvention to be used by this template.
observationConvention(ObservationConvention<?>) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
observationConvention(ObservationConvention<?>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
observationRegistry(ObservationRegistry) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
observationRegistry(ObservationRegistry) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the ObservationRegistry for this container.
observationRegistry(ObservationRegistry) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
observationRegistry(ObservationRegistry) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: Set the ObservationRegistry to be used with this template.
ON_SUCCESS - Enum constant in enum class io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode: Messages will be acknowledged when message processing is successful.
ON_SUCCESS - Static variable in class io.awspring.cloud.sqs.annotation.SqsListenerAcknowledgementMode: Messages will be acknowledged when message processing is successful.
onAcknowledge(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
onAcknowledge(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementCallback: Triggers acknowledgement for the given messages.
onAcknowledge(Message<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
onAcknowledge(Message<T>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementCallback: Triggers acknowledgement for the given message.
onError(Collection<Message<T>>, Throwable, AcknowledgementCallback<T>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementHandler: Invoked when message processing completes with an error for a batch of messages.
onError(Collection<Message<T>>, Throwable, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.AlwaysAcknowledgementHandler
onError(Collection<Message<T>>, Throwable, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.NeverAcknowledgementHandler
onError(Collection<Message<T>>, Throwable, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.OnSuccessAcknowledgementHandler
onError(Message<T>, Throwable, AcknowledgementCallback<T>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementHandler: Invoked when message processing completes with an error for a single message.
onError(Message<T>, Throwable, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.AlwaysAcknowledgementHandler
onError(Message<T>, Throwable, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.NeverAcknowledgementHandler
onError(Message<T>, Throwable, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.OnSuccessAcknowledgementHandler
onFailure(Collection<Message<T>>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementResultCallback: Execute an action if message acknowledgement fails.
onFailure(Collection<Message<T>>, Throwable) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AsyncAcknowledgementResultCallback: Execute an action if message acknowledgement fails.
onInit() - Method in class io.awspring.cloud.sqs.integration.SqsMessageDrivenChannelAdapter
onInit() - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
onMessage(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.adapter.AsyncMessagingMessageListenerAdapter
onMessage(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.adapter.MessagingMessageListenerAdapter
onMessage(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.AsyncMessageListener: Process the provided messages.
onMessage(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.MessageListener
onMessage(Message<T>) - Method in class io.awspring.cloud.sqs.listener.adapter.AsyncMessagingMessageListenerAdapter
onMessage(Message<T>) - Method in class io.awspring.cloud.sqs.listener.adapter.MessagingMessageListenerAdapter
onMessage(Message<T>) - Method in interface io.awspring.cloud.sqs.listener.AsyncMessageListener: Process the provided message.
onMessage(Message<T>) - Method in interface io.awspring.cloud.sqs.listener.MessageListener
onSuccess(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementResultCallback: Execute an action after the messages are successfully acknowledged.
onSuccess(Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.AsyncAcknowledgementResultCallback: Execute an action after the messages are successfully acknowledged.
onSuccess(Collection<Message<T>>, AcknowledgementCallback<T>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementHandler: Invoked when message processing completes successfully for a batch of messages.
onSuccess(Collection<Message<T>>, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.AlwaysAcknowledgementHandler
onSuccess(Collection<Message<T>>, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.NeverAcknowledgementHandler
onSuccess(Collection<Message<T>>, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.OnSuccessAcknowledgementHandler
onSuccess(Message<T>, AcknowledgementCallback<T>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementHandler: Invoked when message processing completes successfully for a single message.
onSuccess(Message<T>, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.AlwaysAcknowledgementHandler
onSuccess(Message<T>, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.NeverAcknowledgementHandler
onSuccess(Message<T>, AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.handler.OnSuccessAcknowledgementHandler
OnSuccessAcknowledgementHandler<T> - Class in io.awspring.cloud.sqs.listener.acknowledgement.handler: AcknowledgementHandler implementation that only acknowledges on success.
OnSuccessAcknowledgementHandler() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.handler.OnSuccessAcknowledgementHandler
ORDERED - Enum constant in enum class io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering: Acknowledgements will be executed sequentially.
ORDERED_BY_GROUP - Enum constant in enum class io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering: Acknowledgements will be executed sequentially within its group, and in parallel between groups.
OrderedMessageSink<T> - Class in io.awspring.cloud.sqs.listener.sink: MessageProcessingPipelineSink implementation that processes provided messages sequentially and in order.
OrderedMessageSink() - Constructor for class io.awspring.cloud.sqs.listener.sink.OrderedMessageSink

P

PARALLEL - Enum constant in enum class io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering: Acknowledgements will be executed in parallel.
PARTIAL_FETCH - Enum constant in enum class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler.ReleaseReason: Some messages were fetched from SQS.
partition(Collection<T>, int) - Static method in class io.awspring.cloud.sqs.CollectionUtils
payload(T) - Method in interface io.awspring.cloud.sqs.operations.SqsSendOptions: Set the payload to send in the message.
phase(Integer) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
pollBackOffPolicy(BackOffPolicy) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
pollBackOffPolicy(BackOffPolicy) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the BackOffPolicy to use when polling throws an exception.
PollingMessageSource<T> - Interface in io.awspring.cloud.sqs.listener.source: MessageSource extension that provides polling configurations and SmartLifecycle capabilities.
pollTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.AbstractContainerOptions.Builder
pollTimeout(Duration) - Method in interface io.awspring.cloud.sqs.listener.ContainerOptionsBuilder: Set the timeout for polling messages for this endpoint.
pollTimeout(Duration) - Method in interface io.awspring.cloud.sqs.operations.SqsReceiveOptions: Set the maximum amount of time to wait for messages in the queue before returning with less than maximum of messages or empty.
pollTimeoutSeconds() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: The maximum number of seconds to wait for messages in a poll to SQS.
pollTimeoutSeconds(Integer) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
postProcessAfterInitialization(Object, String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
preProcessHeadersForReceive(String, Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
preProcessHeadersForReceive(String, Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
preProcessMessageForSend(String, Message<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
preProcessMessageForSend(String, Message<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
preProcessMessageForSendAsync(String, Message<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
preProcessMessageForSendAsync(String, Message<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
preProcessMessagesForSend(String, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
preProcessMessagesForSend(String, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
preProcessMessagesForSendAsync(String, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
preProcessMessagesForSendAsync(String, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
process(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AbstractBeforeProcessingInterceptorExecutionStage
process(Collection<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageListenerExecutionStage
process(Collection<Message<T>>, MessageProcessingContext<T>) - Method in interface io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipeline
process(CompletableFuture<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AbstractAfterProcessingInterceptorExecutionStage
process(CompletableFuture<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AcknowledgementHandlerExecutionStage
process(CompletableFuture<Message<T>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.ErrorHandlerExecutionStage
process(CompletableFuture<Message<T>>, MessageProcessingContext<T>) - Method in interface io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipeline
process(Message<T>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AbstractBeforeProcessingInterceptorExecutionStage
process(Message<T>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageListenerExecutionStage
process(Message<T>, MessageProcessingContext<T>) - Method in interface io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipeline
PROCESS_MESSAGE_GROUPS_IN_PARALLEL_BATCHES - Enum constant in enum class io.awspring.cloud.sqs.listener.FifoBatchGroupingStrategy: Default strategy.
PROCESS_MULTIPLE_GROUPS_IN_SAME_BATCH - Enum constant in enum class io.awspring.cloud.sqs.listener.FifoBatchGroupingStrategy: Each batch contains messages originating from multiple message groups.
PROCESSED - Enum constant in enum class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler.ReleaseReason: The processing of one or more messages finished, successfully or not.
processMany(CompletableFuture<Collection<Message<T>>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AbstractAfterProcessingInterceptorExecutionStage
processMany(CompletableFuture<Collection<Message<T>>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.AcknowledgementHandlerExecutionStage
processMany(CompletableFuture<Collection<Message<T>>>, MessageProcessingContext<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.ErrorHandlerExecutionStage
processMany(CompletableFuture<Collection<Message<T>>>, MessageProcessingContext<T>) - Method in interface io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipeline

Q

queue(String) - Method in interface io.awspring.cloud.sqs.operations.SqsReceiveOptions: Set the queue name, url or ARN from which to receive messages from.
queue(String) - Method in interface io.awspring.cloud.sqs.operations.SqsSendOptions: Set the queue name, url or ARN to send the message to.
queueAttributeNames(Collection<QueueAttributeName>) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
queueAttributeNames(Collection<QueueAttributeName>) - Method in interface io.awspring.cloud.sqs.listener.SqsContainerOptionsBuilder: Set the QueueAttributeNames that will be retrieved from the queue and added as headers to the messages.
queueAttributeNames(Collection<QueueAttributeName>) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateOptions: The queue attribute names that will be retrieved by this template and added as headers to received messages.
queueAttributeNames(Collection<QueueAttributeName>) - Method in class io.awspring.cloud.sqs.QueueAttributesResolver.Builder: The QueueAttributeNames to be retrieved.
QueueAttributes - Class in io.awspring.cloud.sqs.listener: Queue attributes extracted from SQS, as well as the queue name and url.
QueueAttributes(String, String, Map<QueueAttributeName, String>) - Constructor for class io.awspring.cloud.sqs.listener.QueueAttributes: Create an instance with the provided arguments.
QueueAttributesAware - Interface in io.awspring.cloud.sqs.listener: Implementations are enabled to receive a QueueAttributes instance.
QueueAttributesMethodArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: HandlerMethodArgumentResolver implementation for resolving QueueAttributes arguments.
QueueAttributesMethodArgumentResolver() - Constructor for class io.awspring.cloud.sqs.support.resolver.QueueAttributesMethodArgumentResolver
QueueAttributesResolver - Class in io.awspring.cloud.sqs: Resolves QueueAttributes for the specified queue.
QueueAttributesResolver.Builder - Class in io.awspring.cloud.sqs: A builder for creating QueueAttributesResolver instances.
QueueAttributesResolvingException - Exception in io.awspring.cloud.sqs: Exception thrown when a QueueAttributesResolver fails.
QueueAttributesResolvingException(String, Throwable) - Constructor for exception io.awspring.cloud.sqs.QueueAttributesResolvingException: Create an instance with the message and throwable cause.
QueueMessageBatchVisibility - Class in io.awspring.cloud.sqs.listener: BatchVisibility implementation for SQS messages.
QueueMessageBatchVisibility(SqsAsyncClient, String, Collection<String>) - Constructor for class io.awspring.cloud.sqs.listener.QueueMessageBatchVisibility: Create an instance for changing the visibility in batch for the provided queue.
QueueMessageVisibility - Class in io.awspring.cloud.sqs.listener: Visibility implementation for SQS messages.
QueueMessageVisibility(SqsAsyncClient, String, String) - Constructor for class io.awspring.cloud.sqs.listener.QueueMessageVisibility: Create an instance for changing the visibility for the provided queue.
queueName(String) - Method in class io.awspring.cloud.sqs.QueueAttributesResolver.Builder: The queue name.
queueNames() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: Alias for SqsListener.value()
queueNames(String...) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
queueNames(Collection<String>) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
queueNames(Collection<String>) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
queueNames(Collection<String>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
queueNotFoundStrategy(QueueNotFoundStrategy) - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions.BuilderImpl
queueNotFoundStrategy(QueueNotFoundStrategy) - Method in interface io.awspring.cloud.sqs.listener.SqsContainerOptionsBuilder: Set the QueueNotFoundStrategy for the container.
queueNotFoundStrategy(QueueNotFoundStrategy) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateOptions: The QueueNotFoundStrategy for this template.
queueNotFoundStrategy(QueueNotFoundStrategy) - Method in class io.awspring.cloud.sqs.QueueAttributesResolver.Builder: The strategy to be used in case a queue does not exist.
QueueNotFoundStrategy - Enum Class in io.awspring.cloud.sqs.listener: Configure the strategy to be used when a specified queue is not found at container startup.

R

randomSupplier(Supplier<Random>) - Method in class io.awspring.cloud.sqs.listener.errorhandler.ExponentialBackoffErrorHandler.Builder
readableType() - Method in class io.awspring.cloud.sqs.support.observation.MessageHeaderContextAccessor
readValue(MessageHeaders, Object) - Method in class io.awspring.cloud.sqs.support.observation.MessageHeaderContextAccessor
readValues(MessageHeaders, Predicate<Object>, Map<Object, Object>) - Method in class io.awspring.cloud.sqs.support.observation.MessageHeaderContextAccessor
receive() - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receive() - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Receive a message from the default queue with default settings.
receive(String, Class<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receive(String, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Receive a message from the provided queue and convert the payload to the provided class.
receive(Consumer<SqsReceiveOptions>) - Method in interface io.awspring.cloud.sqs.operations.SqsOperations: Receive a message using SqsReceiveOptions.
receive(Consumer<SqsReceiveOptions>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receive(Consumer<SqsReceiveOptions>, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.SqsOperations: Receive a message using SqsReceiveOptions and convert the payload to the provided class.
receive(Consumer<SqsReceiveOptions>, Class<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receiveAsync() - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveAsync() - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Receive a message from the default queue with default settings.
receiveAsync(String, Class<?>, Duration, Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveAsync(String, Class<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveAsync(String, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Receive a message from the provided queue and convert the payload to the provided class.
receiveAsync(Consumer<SqsReceiveOptions>) - Method in interface io.awspring.cloud.sqs.operations.SqsAsyncOperations: Receive a message using the SqsReceiveOptions options.
receiveAsync(Consumer<SqsReceiveOptions>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receiveAsync(Consumer<SqsReceiveOptions>, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.SqsAsyncOperations: Receive a message using the SqsReceiveOptions options and convert the payload to the provided class.
receiveAsync(Consumer<SqsReceiveOptions>, Class<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receiveMany() - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveMany() - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Receive a batch of messages from the default queue with default settings.
receiveMany(String, Class<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveMany(String, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Receive a batch of messages from the provided queue and convert the payloads to the provided class.
receiveMany(Consumer<SqsReceiveOptions>) - Method in interface io.awspring.cloud.sqs.operations.SqsOperations: Receive a batch of messages using SqsReceiveOptions.
receiveMany(Consumer<SqsReceiveOptions>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receiveMany(Consumer<SqsReceiveOptions>, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.SqsOperations: Receive a batch of messages using SqsReceiveOptions and convert the payloads to the provided class.
receiveMany(Consumer<SqsReceiveOptions>, Class<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receiveManyAsync() - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveManyAsync() - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Receive a batch of messages from the default queue with default settings.
receiveManyAsync(String, Class<?>, Duration, Integer, Map<String, Object>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveManyAsync(String, Class<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
receiveManyAsync(String, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Receive a batch of messages from the provided queue and convert the payloads to the provided class.
receiveManyAsync(Consumer<SqsReceiveOptions>) - Method in interface io.awspring.cloud.sqs.operations.SqsAsyncOperations: Receive a batch of messages using the SqsReceiveOptions options.
receiveManyAsync(Consumer<SqsReceiveOptions>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receiveManyAsync(Consumer<SqsReceiveOptions>, Class<T>) - Method in interface io.awspring.cloud.sqs.operations.SqsAsyncOperations: Receive a batch of messages using the SqsReceiveOptions options and convert the payloads to the provided class.
receiveManyAsync(Consumer<SqsReceiveOptions>, Class<T>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
receiveMessage(Consumer<ReceiveMessageRequest.Builder>) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Receives messages from the specified SQS queue using automatic batching.
receiveMessage(ReceiveMessageRequest) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Receives messages from the specified SQS queue using automatic batching.
receiveRequestAttemptId(UUID) - Method in interface io.awspring.cloud.sqs.operations.SqsReceiveOptions: Set the receiveRequestAttemptId required attribute.
registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class io.awspring.cloud.sqs.config.SqsBootstrapConfiguration
registerEndpoint(Endpoint) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Register an Endpoint within this registrar for later processing.
registerListenerContainer(MessageListenerContainer<?>) - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
registerListenerContainer(MessageListenerContainer<?>) - Method in interface io.awspring.cloud.sqs.listener.MessageListenerContainerRegistry: Register a MessageListenerContainer instance with this registry.
release(int) - Method in interface io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler: Deprecated.
This method is deprecated and will not be called by the Spring Cloud AWS SQS listener anymore. Implement BackPressureHandler.release(int, ReleaseReason) instead.
release(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
release(int, BackPressureHandler.ReleaseReason) - Method in interface io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler: Releases the specified amount of permits for processed messages.
release(int, BackPressureHandler.ReleaseReason) - Method in interface io.awspring.cloud.sqs.listener.backpressure.BatchAwareBackPressureHandler
release(int, BackPressureHandler.ReleaseReason) - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler
release(int, BackPressureHandler.ReleaseReason) - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler
release(int, BackPressureHandler.ReleaseReason) - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler
release(int, BackPressureHandler.ReleaseReason) - Method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler
releaseBatch() - Method in interface io.awspring.cloud.sqs.listener.backpressure.BatchAwareBackPressureHandler: Deprecated.
This method is deprecated and will not be called by the Spring Cloud AWS SQS listener anymore. Implement BackPressureHandler.release(int, ReleaseReason) instead.
releaseBatch() - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
releaseUnusedPermits(int, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
removeHeaderIfPresent(Message<T>, String) - Static method in class io.awspring.cloud.sqs.MessageHeaderUtils: Remove the provided header key from the Message if present.
request(int) - Method in interface io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler: Requests a number of permits.
request(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler
request(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler
request(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler
request(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
request(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler
requestBatch() - Method in interface io.awspring.cloud.sqs.listener.backpressure.BatchAwareBackPressureHandler: Request a batch of permits.
requestBatch() - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler
requestBatch() - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler
requestBatch() - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler
requestBatch() - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
resolveAcknowledgement(String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2NotificationSubjectArgumentResolver: Deprecated.
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.AcknowledgmentHandlerMethodArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.BatchAcknowledgmentArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.BatchPayloadMethodArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.BatchVisibilityHandlerMethodArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.legacy.LegacyJackson2NotificationMessageArgumentResolver: Deprecated.
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.legacy.LegacyJackson2SnsNotificationArgumentResolver: Deprecated.
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.NotificationMessageArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.NotificationSubjectArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.QueueAttributesMethodArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.SnsNotificationArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.SqsMessageMethodArgumentResolver
resolveArgument(MethodParameter, Message<?>) - Method in class io.awspring.cloud.sqs.support.resolver.VisibilityHandlerMethodArgumentResolver
resolveAsInteger(String, String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
resolveAsString(String, String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
resolveEndpointNames(String[]) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
resolveQueueAttributes() - Method in class io.awspring.cloud.sqs.QueueAttributesResolver
runBackPressureReleaseCallback() - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext

S

self() - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
semaphoreBackPressureHandler() - Static method in class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactories: Deprecated.
SemaphoreBackPressureHandler - Class in io.awspring.cloud.sqs.listener.backpressure: Deprecated.
SemaphoreBackPressureHandler.Builder - Class in io.awspring.cloud.sqs.listener.backpressure: Deprecated.
send(String, Message<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
send(String, T) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
send(String, Message<T>) - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Send the provided message along with its headers to the provided queue.
send(String, T) - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Send a message to the provided queue with the provided payload.
send(Consumer<SqsSendOptions<T>>) - Method in interface io.awspring.cloud.sqs.operations.SqsOperations: Send a message using the SqsSendOptions options.
send(Consumer<SqsSendOptions<T>>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
send(T) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
send(T) - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Send a Message to the default queue with the provided payload.
sendAsync(String, Message<T>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
sendAsync(String, T) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
sendAsync(String, Message<T>) - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Send the provided message along with its headers to the provided queue.
sendAsync(String, T) - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Send a message to the provided queue with the provided payload.
sendAsync(Consumer<SqsSendOptions<T>>) - Method in interface io.awspring.cloud.sqs.operations.SqsAsyncOperations: Send a message using SqsSendOptions.
sendAsync(Consumer<SqsSendOptions<T>>) - Method in class io.awspring.cloud.sqs.operations.SqsTemplate
sendAsync(T) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
sendAsync(T) - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Send a Message to the default queue with the provided payload.
sendBatchFailureHandlingStrategy(SendBatchFailureHandlingStrategy) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate.AbstractMessagingTemplateOptions
sendBatchFailureHandlingStrategy(SendBatchFailureHandlingStrategy) - Method in interface io.awspring.cloud.sqs.operations.MessagingTemplateOptions: Set the strategy to use when handling batch send operations with at least one failed message.
SendBatchFailureHandlingStrategy - Enum Class in io.awspring.cloud.sqs.operations: The strategy to use when handling a send batch operation that has at least one failed message.
SendBatchOperationFailedException - Exception in io.awspring.cloud.sqs.operations: Exception representing a partial or complete failure in sending a batch of messages to an endpoint.
SendBatchOperationFailedException(String, String, SendResult.Batch<?>) - Constructor for exception io.awspring.cloud.sqs.operations.SendBatchOperationFailedException: Create an instance with the provided arguments.
SendBatchOperationFailedException(String, String, SendResult.Batch<?>, Throwable) - Constructor for exception io.awspring.cloud.sqs.operations.SendBatchOperationFailedException: Create an instance with the provided arguments.
SENDER_FAULT_PARAMETER_NAME - Static variable in class io.awspring.cloud.sqs.operations.SqsTemplateParameters: Whether the messaging operation failed due to a problem with the request.
sendMany(String, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
sendMany(String, Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.operations.MessagingOperations: Send the provided messages along with their headers to the provided queue.
sendManyAsync(String, Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
sendManyAsync(String, Collection<Message<T>>) - Method in interface io.awspring.cloud.sqs.operations.AsyncMessagingOperations: Send the provided messages along with their headers to the provided queue.
sendMessage(Consumer<SendMessageRequest.Builder>) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Sends a message to the specified SQS queue using automatic batching.
sendMessage(SendMessageRequest) - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter: Sends a message to the specified SQS queue using automatic batching.
SendResult<T> - Record Class in io.awspring.cloud.sqs.operations: The result of a send operation.
SendResult(UUID, String, Message<T>, Map<String, Object>) - Constructor for record class io.awspring.cloud.sqs.operations.SendResult: Creates an instance of a SendResult record class.
SendResult.Batch<T> - Record Class in io.awspring.cloud.sqs.operations: The result of a batch send operation.
SendResult.Failed<T> - Record Class in io.awspring.cloud.sqs.operations: The result of a failed send operation.
sendToExecutor(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
SEQUENCE_NUMBER_PARAMETER_NAME - Static variable in class io.awspring.cloud.sqs.operations.SqsTemplateParameters: Sequence number generated for SQS FIFO.
serviceName() - Method in class io.awspring.cloud.sqs.operations.BatchingSqsClientAdapter
setAcknowledgementCallback(AcknowledgementCallback<?>) - Method in interface io.awspring.cloud.sqs.support.converter.AcknowledgementAwareMessageConversionContext
setAcknowledgementCallback(AcknowledgementCallback<?>) - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
setAcknowledgementExecutor(AcknowledgementExecutor<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
setAcknowledgementExecutor(AcknowledgementExecutor<T>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.ExecutingAcknowledgementProcessor
setAcknowledgementProcessor(AcknowledgementProcessor<T>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
setAcknowledgementProcessor(AcknowledgementProcessor<T>) - Method in interface io.awspring.cloud.sqs.listener.source.AcknowledgementProcessingMessageSource: Set the AcknowledgementProcessor instance that will process the message instances and provide the AcknowledgementCallback.
setAcknowledgementResultCallback(AcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Set the AcknowledgementResultCallback instance to be used by containers created by this factory.
setAcknowledgementResultCallback(AcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the AcknowledgementResultCallback instance to be used by this container.
setAcknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Set the AsyncAcknowledgementResultCallback instance to be used by containers created by this factory.
setAcknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the AsyncAcknowledgementResultCallback instance to be used by this container.
setAcknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
setAcknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.ExecutingAcknowledgementProcessor
setAcknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
setAcknowledgementResultCallback(AsyncAcknowledgementResultCallback<T>) - Method in interface io.awspring.cloud.sqs.listener.source.AcknowledgementProcessingMessageSource: Set the AsyncAcknowledgementResultCallback that will be executed after messages are acknowledged, usually by a AcknowledgementExecutor.
setAcknowledgmentCallback(AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext
setAdditionalHeadersFunction(BiFunction<Message, MessageHeaderAccessor, MessageHeaders>) - Method in class io.awspring.cloud.sqs.support.converter.SqsHeaderMapper
setArgumentResolvers(List<HandlerMethodArgumentResolver>) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Set the argument resolvers to be used for inferring payload types if a methodPayloadTypeInferrer is set.
setArgumentResolvers(List<HandlerMethodArgumentResolver>) - Method in interface io.awspring.cloud.sqs.config.HandlerMethodEndpoint: Set the argument resolvers to be used for inferring payload types.
setAsyncMessageListener(AsyncMessageListener<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Set the AsyncMessageListener instance to be used by containers created with this factory.
setAsyncMessageListener(AsyncMessageListener<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
setAsyncMessageListener(AsyncMessageListener<T>) - Method in interface io.awspring.cloud.sqs.listener.MessageListenerContainer: Set the listener to be used to receive messages.
setBackPressureHandler(BackPressureHandler) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
setBackPressureHandler(BackPressureHandler) - Method in interface io.awspring.cloud.sqs.listener.source.PollingMessageSource: Set the BackPressureHandler that will be use to handle backpressure in this source.
setBackPressureReleaseCallback(Runnable) - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext
setBean(Object) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Set the bean instance to be used when handling a message for this endpoint.
setBean(Object) - Method in interface io.awspring.cloud.sqs.config.HandlerMethodEndpoint: Set the bean containing the method to be invoked with the incoming messages.
setBeanFactory(BeanFactory) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor
setBeanFactory(BeanFactory) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar
setComponentFactories(Collection<ContainerComponentFactory<T, O>>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
setContainerComponentFactories(Collection<ContainerComponentFactory<T, O>>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Set the ContainerComponentFactory instances that will be used to create components for listener containers created by this factory.
setDefaultListenerContainerFactoryBeanName(String) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Set the bean name for the default MessageListenerContainerFactory.
setErrorHandler(AsyncErrorHandler<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Set the AsyncErrorHandler instance to be used by containers created with this factory.
setErrorHandler(AsyncErrorHandler<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the AsyncErrorHandler instance to be used by this container.
setErrorHandler(ErrorHandler<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Set the ErrorHandler instance to be used by containers created with this factory.
setErrorHandler(ErrorHandler<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the ErrorHandler instance to be used by this container.
setHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Set the MessageHandlerMethodFactory to be used for handling messages in this endpoint.
setHandlerMethodFactory(MessageHandlerMethodFactory) - Method in interface io.awspring.cloud.sqs.config.HandlerMethodEndpoint: Set the MessageHandlerMethodFactory to be used for creating the HandlerMethod.
setHeaderMapper(HeaderMapper<S>) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Set the HeaderMapper to used to convert headers for Message instances.
setId(String) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the id for this container instance.
setId(String) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
setId(String) - Method in class io.awspring.cloud.sqs.listener.backpressure.CompositeBackPressureHandler
setId(String) - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler
setId(String) - Method in class io.awspring.cloud.sqs.listener.backpressure.FullBatchBackPressureHandler
setId(String) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler: Deprecated.
setId(String) - Method in class io.awspring.cloud.sqs.listener.backpressure.ThroughputBackPressureHandler
setId(String) - Method in interface io.awspring.cloud.sqs.listener.IdentifiableContainerComponent: Set the component id.
setId(String) - Method in interface io.awspring.cloud.sqs.listener.MessageListenerContainer
setId(String) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
setJacksonMessageConverterMigration(JacksonMessageConverterMigration) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Set the object mapper to be used to deserialize payloads fot SqsListener endpoints.
setJsonMapper(JsonMapper) - Method in class io.awspring.cloud.sqs.support.converter.legacy.JacksonJsonMessageConverterMigration: Deprecated.
setListenerContainerRegistry(MessageListenerContainerRegistry) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Set a custom MessageListenerContainerRegistry.
setMaxAcknowledgementsPerBatch(int) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
setMessageGroupingFunction(Function<Message<T>, String>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Set a custom MessageHandlerMethodFactory implementation.
setMessageListener(MessageListener<T>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory: Set the MessageListener instance to be used by containers created with this factory.
setMessageListener(MessageListener<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
setMessageListener(MessageListener<T>) - Method in interface io.awspring.cloud.sqs.listener.MessageListenerContainer: Set the listener to be used to process messages.
setMessageListenerContainerRegistryBeanName(String) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Set the bean name for the MessageListenerContainerRegistry.
setMessagePipeline(MessageProcessingPipeline<T>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
setMessagePipeline(MessageProcessingPipeline<T>) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
setMessagePipeline(MessageProcessingPipeline<T>) - Method in interface io.awspring.cloud.sqs.listener.sink.MessageProcessingPipelineSink: Set the MessageProcessingPipeline instance that this sink will emit Message instances to.
setMessageSink(MessageSink<T>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
setMessageSink(MessageSink<T>) - Method in interface io.awspring.cloud.sqs.listener.source.MessageSource: Set the MessageSink to be used as an output for this MessageSource.
setMessageVisibility(Duration) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.MessageVisibilityExtendingSinkAdapter
setMethod(Method) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Set the method to be used when handling a message for this endpoint.
setMethod(Method) - Method in interface io.awspring.cloud.sqs.config.HandlerMethodEndpoint: Set the method to be used when handling messages for this endpoint.
setMethodPayloadTypeInferrer(MethodPayloadTypeInferrer) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Set the MethodPayloadTypeInferrer to be used for inferring payload types from method signatures.
setMethodPayloadTypeInferrer(MethodPayloadTypeInferrer) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Set the MethodPayloadTypeInferrer to be used for inferring payload types from listener method signatures.
setMethodPayloadTypeInferrer(MethodPayloadTypeInferrer) - Method in interface io.awspring.cloud.sqs.config.HandlerMethodEndpoint: Set the MethodPayloadTypeInferrer to be used for inferring payload types from method signatures.
setObjectMapper(ObjectMapper) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2MessageConverterMigration: Deprecated.
setObjectMapper(ObjectMapper) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SqsMessagingMessageConverter: Deprecated.

Set the ObjectMapper instance to be used for converting the Message instances payloads.
setObservationSpecifics(AbstractListenerObservation.Specifics<?>) - Method in interface io.awspring.cloud.sqs.listener.ObservableComponent: Set the Observation-related instances that are specific to a messaging system.
setObservationSpecifics(AbstractListenerObservation.Specifics<?>) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
setObservationSpecifics(AbstractListenerObservation.Specifics<?>) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
setParallelLifecycle(boolean) - Method in class io.awspring.cloud.sqs.LifecycleHandler: Set whether lifecycle management should be handled in parallel or sequentially.
setPayloadClass(Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
setPayloadDeserializationType(Class<?>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the target type for payload deserialization.
setPayloadDeserializationType(Class<?>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource: Set the payload deserialization type.
setPayloadMessageConverter(MessageConverter) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Set the MessageConverter to be used for converting the Message instances payloads.
setPayloadTypeHeader(String) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Set the name of the header to be looked up in a Message instance for payload type mapping.
setPayloadTypeHeaderValueFunction(Function<Message<?>, String>) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Set the function to create the payload type header value from.
setPayloadTypeMapper(Function<Message<?>, Class<?>>) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter: Set the payload type mapper to be used by this converter.
setPhase(int) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the phase for the SmartLifecycle for this container instance.
setPhase(int) - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
setPollingEndpointName(String) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
setPollingEndpointName(String) - Method in interface io.awspring.cloud.sqs.listener.source.PollingMessageSource: Set the endpoint name that will be polled by this source.
setQueue(String) - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
setQueueAttributes(QueueAttributes) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.SqsAcknowledgementExecutor
setQueueAttributes(QueueAttributes) - Method in interface io.awspring.cloud.sqs.listener.QueueAttributesAware: Set the QueueAttributes instance.
setQueueAttributes(QueueAttributes) - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
setQueueExpression(Expression) - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
setQueueExpressionString(String) - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
setQueueNames(String...) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the queue logical names that will be handled by the container.
setQueueNames(Collection<String>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer: Set the queue logical names that will be handled by the container.
setQueueNames(Collection<String>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
setSendResult(SendResult<?>) - Method in class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Context: Set the send result for this context.
setSendTimeout(long) - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
setSendTimeoutExpression(Expression) - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
setSendTimeoutExpressionString(String) - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
setSqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory: Set the SqsAsyncClient instance to be shared by the containers.
setSqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.SqsAcknowledgementExecutor
setSqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
setSqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.MessageVisibilityExtendingSinkAdapter
setSqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource
setSqsAsyncClient(SqsAsyncClient) - Method in interface io.awspring.cloud.sqs.listener.SqsAsyncClientAware: Set the SqsAsyncClient instance.
setSqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
setSqsAsyncClientSupplier(Supplier<SqsAsyncClient>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory: Set a supplier for SqsAsyncClient instances.
setSqsContainerOptions(SqsContainerOptions) - Method in class io.awspring.cloud.sqs.integration.SqsMessageDrivenChannelAdapter
setTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.BatchingAcknowledgementProcessor
setTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters.AbstractThreadingComponentAdapter
setTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
setTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
setTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
setTaskExecutor(TaskExecutor) - Method in interface io.awspring.cloud.sqs.listener.TaskExecutorAware: Set the task executor.
setupAcknowledgementForConversion(AcknowledgementCallback<T>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource
setupContainer(MessageListenerContainer<T>) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint: Configure the provided container for this endpoint.
setupContainer(MessageListenerContainer<T>) - Method in interface io.awspring.cloud.sqs.config.Endpoint: Set up the necessary attributes for the container to process this endpoint.
setupContainer(MessageListenerContainer<T>) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint
setValidator(Validator) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar: Set the Validator instance used for payload validating in HandlerMethodArgumentResolver instances.
shouldCopyRequestHeaders() - Method in class io.awspring.cloud.sqs.integration.SqsMessageHandler
SimpleClassMatchingMessageConverter - Class in io.awspring.cloud.sqs.support.converter: SmartMessageConverter implementation that returns the payload unchanged if the target class for Serialization / Deserialization matches the payload class.
SimpleClassMatchingMessageConverter() - Constructor for class io.awspring.cloud.sqs.support.converter.SimpleClassMatchingMessageConverter
SINGLE_MESSAGE - Enum constant in enum class io.awspring.cloud.sqs.listener.ListenerMode: Configure the container to receive one message at a time in its components.
SnsJsonNode - Class in io.awspring.cloud.sqs.support.converter
SnsJsonNode(JsonMapper, String) - Constructor for class io.awspring.cloud.sqs.support.converter.SnsJsonNode
SnsMessageConverter - Class in io.awspring.cloud.sqs.support.converter
SnsMessageConverter(MessageConverter, JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.SnsMessageConverter
SnsNotification<T> - Class in io.awspring.cloud.sqs.support.converter: Wrapper for SNS notifications that provides access to both the message payload and metadata.
SnsNotification(String, String, String, T, String, Map<String, SnsNotification.MessageAttribute>, String, String, String, String, String, String) - Constructor for class io.awspring.cloud.sqs.support.converter.SnsNotification
SnsNotification.MessageAttribute - Class in io.awspring.cloud.sqs.support.converter: Represents an SNS message attribute.
SnsNotificationArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: Resolves method parameters with SnsNotification object.
SnsNotificationArgumentResolver(MessageConverter, JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.resolver.SnsNotificationArgumentResolver: Creates a new resolver with the given converter and JSON mapper.
SnsNotificationConverter - Class in io.awspring.cloud.sqs.support.converter: Converter that extracts SNS notifications from SQS messages and creates SnsNotification objects.
SnsNotificationConverter(MessageConverter, JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.SnsNotificationConverter: Creates a new converter with the given payload converter and JSON mapper.
SnsNotificationMessage - Annotation Interface in io.awspring.cloud.sqs.annotation: Annotation that is used to map SNS notification value on an SQS Queue to a variable that is annotated.
SnsNotificationSubject - Annotation Interface in io.awspring.cloud.sqs.annotation: Annotation that is used to map SNS notification subject on an SQS Queue to a variable that is annotated.
SnsSubjectConverter - Class in io.awspring.cloud.sqs.support.converter
SnsSubjectConverter(JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.SnsSubjectConverter
SQS_APPROXIMATE_FIRST_RECEIVE_TIMESTAMP - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: ApproximateFirstReceiveTimestamp header in a SQS message.
SQS_APPROXIMATE_RECEIVE_COUNT - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: ApproximateReceiveCount header in a SQS message.
SQS_AWS_TRACE_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: Tracing header in the SQS message request.
SQS_DEFAULT_TYPE_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header containing the FQCN of the Class that the message's payload should be deserialized to.
SQS_DELAY_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the delay attribute.
SQS_HEADER_PREFIX - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: SQS Headers prefix to be used by all headers added by the framework.
SQS_LISTENER_ANNOTATION_BEAN_POST_PROCESSOR_BEAN_NAME - Static variable in class io.awspring.cloud.sqs.config.SqsBeanNames: The bean name of the SqsListenerAnnotationBeanPostProcessor registered by SqsBootstrapConfiguration.
SQS_MESSAGE_DEDUPLICATION_ID_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: Deduplication header in a SQS message.
SQS_MESSAGE_GROUP_ID_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: Group id header in a SQS message.
SQS_MSA_HEADER_PREFIX - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: MessageSystemAttributes prefix
SQS_QUEUE_ATTRIBUTES_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the QueueAttributes for this message.
SQS_QUEUE_NAME_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the queue name.
SQS_QUEUE_URL_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the queue url.
SQS_RECEIPT_HANDLE_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the SQS Message's receipt handle.
SQS_RECEIVE_REQUEST_ATTEMPT_ID_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the ReceiveRequestAttemptId for this message.
SQS_RECEIVED_AT_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the received at attribute.
SQS_SENDER_ID - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: SenderId header in a SQS message.
SQS_SENT_TIMESTAMP - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: SentTimestamp header in a SQS message.
SQS_SEQUENCE_NUMBER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttributes: Sequence number header from an SQS send result.
SQS_SOURCE_DATA_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the original SQS Message.
SQS_VISIBILITY_TIMEOUT_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders: Header for the Visibility object for this message.
SqsAcknowledgementException - Exception in io.awspring.cloud.sqs: Exception representing an error during acknowledgement execution.
SqsAcknowledgementException(String, Collection<Message<?>>, Collection<Message<?>>, String) - Constructor for exception io.awspring.cloud.sqs.SqsAcknowledgementException: Construct an instance with the given parameters.
SqsAcknowledgementException(String, Collection<Message<?>>, Collection<Message<?>>, String, Throwable) - Constructor for exception io.awspring.cloud.sqs.SqsAcknowledgementException: Construct an instance with the given parameters.
SqsAcknowledgementExecutor<T> - Class in io.awspring.cloud.sqs.listener.acknowledgement: AcknowledgementExecutor implementation for SQS queues.
SqsAcknowledgementExecutor() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.SqsAcknowledgementExecutor
sqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder: Set the SqsAsyncClient instance to be shared by the containers.
sqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder
sqsAsyncClient(SqsAsyncClient) - Method in interface io.awspring.cloud.sqs.operations.SqsTemplateBuilder: Set the SqsAsyncClient to be used by the SqsTemplate.
sqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.QueueAttributesResolver.Builder: The SqsAsyncClient to be used to resolve the queue attributes.
SqsAsyncClientAware - Interface in io.awspring.cloud.sqs.listener: Implementations are enabled to receive a SqsAsyncClient instance.
sqsAsyncClientSupplier(Supplier<SqsAsyncClient>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder: Set a supplier for SqsAsyncClient instances.
SqsAsyncOperations - Interface in io.awspring.cloud.sqs.operations: Sqs-specific asynchronous messaging operations for Standard and Fifo queues.
SqsBeanNames - Class in io.awspring.cloud.sqs.config: Utility class containing the bean names used for the framework's bean registration.
SqsBootstrapConfiguration - Class in io.awspring.cloud.sqs.config: Registers the DefaultListenerContainerRegistry and EndpointRegistrar that will be used to bootstrap the AWS SQS integration.
SqsBootstrapConfiguration() - Constructor for class io.awspring.cloud.sqs.config.SqsBootstrapConfiguration
SqsContainerOptions - Class in io.awspring.cloud.sqs.listener: Sqs specific implementation of ContainerOptions.
SqsContainerOptions.BuilderImpl - Class in io.awspring.cloud.sqs.listener
SqsContainerOptionsBuilder - Interface in io.awspring.cloud.sqs.listener: ContainerOptionsBuilder specialization for SQS specific options.
sqsEndpoint(Endpoint) - Method in class io.awspring.cloud.sqs.config.MultiMethodSqsEndpoint.MultiMethodSqsEndpointBuilder
SqsEndpoint - Class in io.awspring.cloud.sqs.config: Endpoint implementation for SQS endpoints.
SqsEndpoint(SqsEndpoint.SqsEndpointBuilder) - Constructor for class io.awspring.cloud.sqs.config.SqsEndpoint
SqsEndpoint.SqsEndpointBuilder - Class in io.awspring.cloud.sqs.config
SqsEndpointBuilder() - Constructor for class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder
SqsException - Exception in io.awspring.cloud.sqs: Top-level exception for Sqs RuntimeException instances.
SqsException(String, Throwable) - Constructor for exception io.awspring.cloud.sqs.SqsException: Construct an instance with the supplied message and cause.
SqsHandler - Annotation Interface in io.awspring.cloud.sqs.annotation: 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 - Class in io.awspring.cloud.sqs.support.converter: A HeaderMapper implementation for SQS Messages.
SqsHeaderMapper() - Constructor for class io.awspring.cloud.sqs.support.converter.SqsHeaderMapper
SqsHeaders - Class in io.awspring.cloud.sqs.listener: The MessageHeaders names used for Message instances created from SQS messages.
SqsHeaders.MessageSystemAttributes - Class in io.awspring.cloud.sqs.listener
SqsJacksonVersion - Enum Class in io.awspring.cloud.sqs.operations: Deprecated, for removal: This API element is subject to removal in a future version.
SqsListener - Annotation Interface in io.awspring.cloud.sqs.annotation: Methods with this annotation will be wrapped by a MessageListener or AsyncMessageListener and set to a MessageListenerContainer.
SqsListenerAcknowledgementMode - Class in io.awspring.cloud.sqs.annotation: Acknowledgement strategies supported by the SqsListener annotation.
SqsListenerAcknowledgementMode() - Constructor for class io.awspring.cloud.sqs.annotation.SqsListenerAcknowledgementMode
SqsListenerAnnotationBeanPostProcessor - Class in io.awspring.cloud.sqs.annotation: AbstractListenerAnnotationBeanPostProcessor implementation for @SqsListener.
SqsListenerAnnotationBeanPostProcessor() - Constructor for class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor
SqsListenerConfigurer - Interface in io.awspring.cloud.sqs.config: Beans implementing this interface can configure the EndpointRegistrar instance used to process Endpoint instances and change general settings for processing all SqsListener annotations.
SqsListenerObservation - Class in io.awspring.cloud.sqs.support.observation: SQS-specific Observation for SqsMessageListenerContainer.
SqsListenerObservation() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsListenerObservation
SqsListenerObservation.Context - Class in io.awspring.cloud.sqs.support.observation: SqsListenerObservation.Context for SQS message listeners.
SqsListenerObservation.Convention - Interface in io.awspring.cloud.sqs.support.observation: ObservationConvention for SQS message listener key values.
SqsListenerObservation.DefaultConvention - Class in io.awspring.cloud.sqs.support.observation: ObservationConvention for SQS listener key values.
SqsListenerObservation.Documentation - Class in io.awspring.cloud.sqs.support.observation: ObservationDocumentation for SQS message listener keys.
SqsListenerObservation.Documentation.HighCardinalityTags - Enum Class in io.awspring.cloud.sqs.support.observation: SQS-specific high cardinality tags.
SqsListenerObservation.SqsSpecifics - Class in io.awspring.cloud.sqs.support.observation: Observation-related instances that are specific to SQS.
SqsMessageConversionContext - Class in io.awspring.cloud.sqs.support.converter: MessageConversionContext implementation that contains SQS related properties for mapping additional MessageHeaders.
SqsMessageConversionContext() - Constructor for class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext
SqsMessageDrivenChannelAdapter - Class in io.awspring.cloud.sqs.integration: The MessageProducerSupport implementation for the Amazon SQS receiveMessage.
SqsMessageDrivenChannelAdapter(SqsAsyncClient, String...) - Constructor for class io.awspring.cloud.sqs.integration.SqsMessageDrivenChannelAdapter
SqsMessageHandler - Class in io.awspring.cloud.sqs.integration: The AbstractMessageProducingHandler implementation for the Amazon SQS.
SqsMessageHandler(SqsAsyncOperations) - Constructor for class io.awspring.cloud.sqs.integration.SqsMessageHandler
SqsMessageListenerContainer<T> - Class in io.awspring.cloud.sqs.listener: MessageListenerContainer implementation for SQS queues.
SqsMessageListenerContainer(SqsAsyncClient) - Constructor for class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
SqsMessageListenerContainer(SqsAsyncClient, SqsContainerOptions) - Constructor for class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer
SqsMessageListenerContainer.Builder<T> - Class in io.awspring.cloud.sqs.listener
SqsMessageListenerContainerFactory<T> - Class in io.awspring.cloud.sqs.config: MessageListenerContainerFactory implementation for creating SqsMessageListenerContainer instances.
SqsMessageListenerContainerFactory() - Constructor for class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory
SqsMessageListenerContainerFactory.Builder<T> - Class in io.awspring.cloud.sqs.config
SqsMessageMethodArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: Resolves original SQS message object {@link (software.amazon.awssdk.services.sqs.model.Message)} from Spring Messaging message object Message.
SqsMessageMethodArgumentResolver() - Constructor for class io.awspring.cloud.sqs.support.resolver.SqsMessageMethodArgumentResolver
SqsMessagingMessageConverter - Class in io.awspring.cloud.sqs.support.converter: MessagingMessageConverter implementation for converting SQS Message instances to Spring Messaging Message instances.
SqsMessagingMessageConverter() - Constructor for class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter
SqsMessagingMessageConverter(JsonMapper) - Constructor for class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter
SqsOperations - Interface in io.awspring.cloud.sqs.operations: Sqs-specific synchronous messaging operations for Standard and Fifo queues.
SqsReceiveOptions - Interface in io.awspring.cloud.sqs.operations: Options for receiving messages from SQS queues, with a method chaining API.
SqsSendOptions<T> - Interface in io.awspring.cloud.sqs.operations: Options for sending messages to SQS queues, with a method chaining API.
SqsSpecifics() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.SqsSpecifics
SqsSpecifics() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.SqsSpecifics
SqsTemplate - Class in io.awspring.cloud.sqs.operations: Sqs-specific implementation of AbstractMessagingTemplate
SqsTemplateBuilder - Interface in io.awspring.cloud.sqs.operations: Builder interface for creating a SqsTemplate instance.
SqsTemplateObservation - Class in io.awspring.cloud.sqs.support.observation: Observation for SqsTemplate.
SqsTemplateObservation() - Constructor for class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation
SqsTemplateObservation.Context - Class in io.awspring.cloud.sqs.support.observation: SqsListenerObservation.Context for SqsTemplate.
SqsTemplateObservation.Convention - Interface in io.awspring.cloud.sqs.support.observation: ObservationConvention for SqsTemplate key values.
SqsTemplateObservation.DefaultConvention - Class in io.awspring.cloud.sqs.support.observation: ObservationConvention for SQS template key values.
SqsTemplateObservation.Documentation - Class in io.awspring.cloud.sqs.support.observation: ObservationDocumentation for SqsTemplate keys.
SqsTemplateObservation.Documentation.HighCardinalityTags - Enum Class in io.awspring.cloud.sqs.support.observation: High cardinality tags.
SqsTemplateObservation.SqsSpecifics - Class in io.awspring.cloud.sqs.support.observation: Observation-related instances that are specific to SQS.
SqsTemplateOptions - Interface in io.awspring.cloud.sqs.operations: Sqs specific options for the SqsTemplate.
SqsTemplateParameters - Class in io.awspring.cloud.sqs.operations: SQS parameters added to SendResult objects as additional information.
SqsTemplateParameters() - Constructor for class io.awspring.cloud.sqs.operations.SqsTemplateParameters
StandardSqsComponentFactory<T> - Class in io.awspring.cloud.sqs.listener: A ContainerComponentFactory implementation for Standard SQS queues.
StandardSqsComponentFactory() - Constructor for class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
StandardSqsMessageSource<T> - Class in io.awspring.cloud.sqs.listener.source: AbstractSqsMessageSource implementation for standard queues.
StandardSqsMessageSource() - Constructor for class io.awspring.cloud.sqs.listener.source.StandardSqsMessageSource
start() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
start() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
start() - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
start() - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
start() - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
start() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
start(Object...) - Method in class io.awspring.cloud.sqs.LifecycleHandler: Starts the provided objects that are a SmartLifecycle instance.
stop() - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer
stop() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor
stop() - Method in class io.awspring.cloud.sqs.listener.DefaultListenerContainerRegistry
stop() - Method in class io.awspring.cloud.sqs.listener.sink.AbstractMessageProcessingPipelineSink
stop() - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter
stop() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource
stop(Object...) - Method in class io.awspring.cloud.sqs.LifecycleHandler: Starts the provided objects that are a SmartLifecycle instance.
STRING - Static variable in class io.awspring.cloud.sqs.support.converter.MessageAttributeDataTypes: String message attribute data type.
STRING_ARRAY - Static variable in class io.awspring.cloud.sqs.support.converter.MessageAttributeDataTypes: String.Array message attribute data type.
successful() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Batch: Returns the value of the successful record component.
supports(Class<?>) - Method in class io.awspring.cloud.sqs.support.converter.SimpleClassMatchingMessageConverter
supports(Collection<String>, SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory
supports(Collection<String>, SqsContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory
supports(Collection<String>, O) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory: Whether this factory supports the given queues based on the queue names.
supportsContext(Observation.Context) - Method in interface io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Convention
supportsContext(Observation.Context) - Method in interface io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Convention
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2NotificationSubjectArgumentResolver: Deprecated.
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.AcknowledgmentHandlerMethodArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.BatchAcknowledgmentArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.BatchPayloadMethodArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.BatchVisibilityHandlerMethodArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.legacy.LegacyJackson2NotificationMessageArgumentResolver: Deprecated.
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.legacy.LegacyJackson2SnsNotificationArgumentResolver: Deprecated.
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.NotificationMessageArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.NotificationSubjectArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.QueueAttributesMethodArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.SnsNotificationArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.SqsMessageMethodArgumentResolver
supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sqs.support.resolver.VisibilityHandlerMethodArgumentResolver

T

TaskExecutorAware - Interface in io.awspring.cloud.sqs.listener: Enables a class to receive a container managed TaskExecutor.
TemplateAcknowledgementMode - Enum Class in io.awspring.cloud.sqs.operations: Acknowledgement modes to be used by a MessageReceivingOperations implementation.
TemplateContentBasedDeduplication - Enum Class in io.awspring.cloud.sqs.operations: The ContentBasedDeduplication queue attribute value to be used by the SqsTemplate when sending messages to a FIFO queue.
then(Function<MessageProcessingConfiguration<T>, MessageProcessingPipeline<T>>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder
thenInTheFuture(Function<MessageProcessingConfiguration<T>, MessageProcessingPipeline<T>>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder
thenWrapWith(BiFunction<MessageProcessingConfiguration<T>, MessageProcessingPipeline<T>, MessageProcessingPipeline<T>>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder
throughputBackPressureHandler() - Static method in class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandlerFactories: Creates a new ThroughputBackPressureHandler using the provided ContainerOptions.
ThroughputBackPressureHandler - Class in io.awspring.cloud.sqs.listener.backpressure: A non-blocking BackPressureHandler that dynamically switches between high- and low-throughput modes to optimize polling behavior based on recent message availability.
ThroughputBackPressureHandler.Builder - Class in io.awspring.cloud.sqs.listener.backpressure
throughputConfiguration(BackPressureMode) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler.Builder: Deprecated.
THROW - Enum constant in enum class io.awspring.cloud.sqs.operations.SendBatchFailureHandlingStrategy: Throw a SendBatchOperationFailedException containing a SendResult.Batch object.
toBatchVisibility(Collection<Message<?>>) - Method in class io.awspring.cloud.sqs.listener.QueueMessageVisibility: Create a BatchVisibility instance with the provided messages' receipt handlers.
toBuilder() - Method in interface io.awspring.cloud.sqs.listener.ContainerOptions: Creates a new ) instance configured with this options. Note that any changes made to the builder will have no effect on this object.
toBuilder() - Method in class io.awspring.cloud.sqs.listener.SqsContainerOptions
toHeaders(S) - Method in interface io.awspring.cloud.sqs.support.converter.HeaderMapper: Map the provided source into a MessageHeaders instance.
toHeaders(Message) - Method in class io.awspring.cloud.sqs.support.converter.SqsHeaderMapper
toMessage(Object, MessageHeaders) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsMessageConverter: Deprecated.
toMessage(Object, MessageHeaders) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsNotificationConverter: Deprecated.
toMessage(Object, MessageHeaders) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsSubjectConverter: Deprecated.
toMessage(Object, MessageHeaders) - Method in class io.awspring.cloud.sqs.support.converter.SnsMessageConverter
toMessage(Object, MessageHeaders) - Method in class io.awspring.cloud.sqs.support.converter.SnsNotificationConverter
toMessage(Object, MessageHeaders) - Method in class io.awspring.cloud.sqs.support.converter.SnsSubjectConverter
toMessage(Object, MessageHeaders, Object) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsMessageConverter: Deprecated.
toMessage(Object, MessageHeaders, Object) - Method in class io.awspring.cloud.sqs.support.converter.legacy.LegacyJackson2SnsNotificationConverter: Deprecated.
toMessage(Object, MessageHeaders, Object) - Method in class io.awspring.cloud.sqs.support.converter.SnsMessageConverter
toMessage(Object, MessageHeaders, Object) - Method in class io.awspring.cloud.sqs.support.converter.SnsNotificationConverter
toMessagingMessage(S) - Method in interface io.awspring.cloud.sqs.support.converter.ContextAwareMessagingMessageConverter
toMessagingMessage(S) - Method in interface io.awspring.cloud.sqs.support.converter.MessagingMessageConverter: Convert a source message from a specific messaging system to a Message.
toMessagingMessage(S, MessageConversionContext) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter
toMessagingMessage(S, MessageConversionContext) - Method in interface io.awspring.cloud.sqs.support.converter.ContextAwareMessagingMessageConverter: Convert a source message from a specific messaging system to a Message with an optional context.
toString() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Batch: Returns a string representation of this record class.
toString() - Method in record class io.awspring.cloud.sqs.operations.SendResult.Failed: Returns a string representation of this record class.
toString() - Method in record class io.awspring.cloud.sqs.operations.SendResult: Returns a string representation of this record class.
totalPermits(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler.Builder
totalPermits(int) - Method in class io.awspring.cloud.sqs.listener.backpressure.SemaphoreBackPressureHandler.Builder: Deprecated.

U

UnsupportedThreadFactoryException - Exception in io.awspring.cloud.sqs: Exception thrown when an executor is provided with an unsupported ThreadFactory.
UnsupportedThreadFactoryException(String, Throwable) - Constructor for exception io.awspring.cloud.sqs.UnsupportedThreadFactoryException: Create an instance with the provided error message and cause.
UnsupportedThreadFactoryException(String) - Constructor for exception io.awspring.cloud.sqs.UnsupportedThreadFactoryException: Create an instance with the provided error message.
unwrapCompletionException(CompletableFuture<V>) - Method in class io.awspring.cloud.sqs.operations.AbstractMessagingTemplate
unwrapException(Throwable, Class<? extends Throwable>...) - Static method in class io.awspring.cloud.sqs.ExceptionUtils: Unwraps the original exception until an exception not in the provided exceptions is found.
unwrapMessage(Throwable) - Static method in interface io.awspring.cloud.sqs.listener.MessageProcessingException: Look for a potentially nested MessageProcessingException in the cause chain and if found return the wrapped Message instance.
unwrapMessage(Throwable) - Static method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException: Deprecated.
use MessageProcessingException.unwrapMessage(Throwable) instead.
unwrapMessages(Throwable) - Static method in interface io.awspring.cloud.sqs.listener.MessageProcessingException: Look for a potentially nested MessageProcessingException in the cause chain and if found return the wrapped Message instances.
unwrapMessages(Throwable) - Static method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException: Deprecated.
use MessageProcessingException.unwrapMessages(Throwable) instead.

V

validate(Message<?>, MethodParameter, Object) - Method in class io.awspring.cloud.sqs.support.resolver.BatchPayloadMethodArgumentResolver: Validate the payload if applicable.
value() - Element in annotation interface io.awspring.cloud.sqs.annotation.SqsListener: Array of queue names or urls.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler.ReleaseReason: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.listener.BackPressureMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.listener.FifoBatchGroupingStrategy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.listener.ListenerMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.listener.QueueNotFoundStrategy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.operations.SendBatchFailureHandlingStrategy: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.operations.SqsJacksonVersion: Deprecated.

Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.operations.TemplateAcknowledgementMode: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.operations.TemplateContentBasedDeduplication: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.HighCardinalityTags: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.LowCardinalityTags: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.HighCardinalityTags: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.LowCardinalityTags: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Documentation.HighCardinalityTags: Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Documentation.HighCardinalityTags: Returns the enum constant of this class with the specified name.
values() - Static method in enum class io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.listener.backpressure.BackPressureHandler.ReleaseReason: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.listener.BackPressureMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.listener.FifoBatchGroupingStrategy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.listener.ListenerMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.listener.QueueNotFoundStrategy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.operations.SendBatchFailureHandlingStrategy: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.operations.SqsJacksonVersion: Deprecated.

Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.operations.TemplateAcknowledgementMode: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.operations.TemplateContentBasedDeduplication: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.HighCardinalityTags: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractListenerObservation.Documentation.LowCardinalityTags: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.HighCardinalityTags: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.support.observation.AbstractTemplateObservation.Documentation.LowCardinalityTags: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Documentation.HighCardinalityTags: Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Documentation.HighCardinalityTags: Returns an array containing the constants of this enum class, in the order they are declared.
Visibility - Interface in io.awspring.cloud.sqs.listener: Visibility interface that can be injected as parameter into a listener method.
VisibilityHandlerMethodArgumentResolver - Class in io.awspring.cloud.sqs.support.resolver: HandlerMethodArgumentResolver for Visibility method parameters.
VisibilityHandlerMethodArgumentResolver(String) - Constructor for class io.awspring.cloud.sqs.support.resolver.VisibilityHandlerMethodArgumentResolver
visibilityTimeout(Duration) - Method in interface io.awspring.cloud.sqs.operations.SqsReceiveOptions: Set the visibility timeout to be applied by received messages.

W

withConsumerThreadLocalScope(Consumer<Message<MessageType>>, Message<MessageType>) - Method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters.AbstractThreadingComponentAdapter
withFunctionThreadLocalScope(Function<Message<MessageType>, Message<MessageType>>, Message<MessageType>) - Method in class io.awspring.cloud.sqs.listener.AsyncComponentAdapters.AbstractThreadingComponentAdapter
writeableType() - Method in class io.awspring.cloud.sqs.support.observation.MessageHeaderContextAccessor
writeValues(Map<Object, Object>, MessageHeaders) - Method in class io.awspring.cloud.sqs.support.observation.MessageHeaderContextAccessor

A B C D E F G H I J L M N O P Q R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form