Index

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

abortMultipartUpload(AbortMultipartUploadRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

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

AbstractAwsConfigDataLocationResolver<T extends org.springframework.boot.context.config.ConfigDataResource> - Class in io.awspring.cloud.autoconfigure.config

Base class for AWS specific ConfigDataLocationResolvers.

AbstractAwsConfigDataLocationResolver() - Constructor for class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

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

AbstractCrossRegionS3ClientGenerator - Class in io.awspring.cloud.s3.codegen

Generates AbstractCrossRegionS3Client class from AbstractCrossRegionS3ClientTemplate.

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

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> - Class in io.awspring.cloud.sqs.listener

Base implementation for MessageListenerContainer with SmartLifecycle and component management capabilities.

AbstractMessageListenerContainer(ContainerOptions) - Constructor for class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer

Create an instance with the provided ContainerOptions

AbstractMessageListenerContainerFactory<T,C extends MessageListenerContainer<T>> - Class in io.awspring.cloud.sqs.config

Base implementation for a MessageListenerContainerFactory.

AbstractMessageListenerContainerFactory() - 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

MessagingMessageConverter implementation for converting SQS Message instances to Spring Messaging Message instances.

AbstractMessagingMessageConverter() - Constructor for class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter

AbstractMethodInvokingListenerAdapter<T> - Class in io.awspring.cloud.sqs.listener.adapter

Base class for invoking an InvocableHandlerMethod.

AbstractMethodInvokingListenerAdapter(InvocableHandlerMethod) - Constructor for class io.awspring.cloud.sqs.listener.adapter.AbstractMethodInvokingListenerAdapter

Create an instance with the provided InvocableHandlerMethod.

AbstractNotificationMessageHandlerMethodArgumentResolver - Class in io.awspring.cloud.sns.handlers

AbstractNotificationMessageHandlerMethodArgumentResolver() - Constructor for class io.awspring.cloud.sns.handlers.AbstractNotificationMessageHandlerMethodArgumentResolver

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> - Class in io.awspring.cloud.sqs.listener

Base MessageListenerContainer implementation for managing Message instances' lifecycles.

AbstractPipelineMessageListenerContainer(ContainerOptions) - 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

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

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

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>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.BatchAcknowledgement

Acknowledge the provided 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>>) - Method in interface io.awspring.cloud.sqs.listener.acknowledgement.BatchAcknowledgement

Asynchronously acknowledge the provided messages.

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.ContainerOptions.Builder

acknowledgementMode(AcknowledgementMode) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

AcknowledgementMode - Enum 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.ContainerOptions.Builder

AcknowledgementOrdering - Enum 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.ContainerOptions.Builder

acknowledgementThreshold(int) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

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

acl(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

acl(ObjectCannedACL) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

acquireTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler.Builder

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

addInterceptor(AsyncMessageInterceptor<T>) - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext

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.

aDepartment() - Static method in class io.awspring.cloud.samples.dynamodb.Department.Builder

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

afterPropertiesSet() - Method in class io.awspring.cloud.autoconfigure.config.reload.PollingAwsPropertySourceChangeDetector

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 io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode

Messages will be acknowledged whether processing was completed successfully or with an error.

ALWAYS_POLL_MAX_MESSAGES - Enum constant in enum 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.

AlwaysAcknowledgementHandler() - Constructor for class io.awspring.cloud.sqs.listener.acknowledgement.handler.AlwaysAcknowledgementHandler

analyze(Throwable, ParameterStoreKeysMissingException) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreMissingKeysFailureAnalyzer

analyze(Throwable, SecretsManagerKeysMissingException) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerMissingKeysFailureAnalyzer

App - Class in io.awspring.cloud.samples.secretsmanager

Secrets from the Secret Manager are added to the Environment and can be retrieved using: - Value annotation - PropertyResolver.getProperty(String) - or bound to ConfigurationProperties annotated classes.

App() - Constructor for class io.awspring.cloud.samples.secretsmanager.App

applicationRunner(SnsTemplate, SnsClient, SnsSmsTemplate) - Method in class io.awspring.cloud.sns.sample.SpringSNSSample

apply(AwsClientCustomizer<V>, V) - Static method in interface io.awspring.cloud.autoconfigure.core.AwsClientCustomizer

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 - 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.

asyncHttpClient() - Method in interface io.awspring.cloud.autoconfigure.core.AwsClientCustomizer

asyncHttpClientBuilder() - Method in interface io.awspring.cloud.autoconfigure.core.AwsClientCustomizer

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

AUTO - Enum constant in enum io.awspring.cloud.sqs.listener.BackPressureMode

Enable automatic throughput switching and partial batch polling.

AutoConfigureSqs - Annotation Type in io.awspring.cloud.test.sqs

Auto-configuration imports for typical SQS tests.

AwsAutoConfiguration - Class in io.awspring.cloud.autoconfigure.core

Autoconfigures AWS environment.

AwsAutoConfiguration(AwsProperties) - Constructor for class io.awspring.cloud.autoconfigure.core.AwsAutoConfiguration

awsClientBuilderConfigurer(AwsCredentialsProvider, AwsRegionProvider) - Method in class io.awspring.cloud.autoconfigure.core.AwsAutoConfiguration

AwsClientBuilderConfigurer - Class in io.awspring.cloud.autoconfigure.core

Provides a convenience method to apply common configuration to any AwsClientBuilder.

AwsClientCustomizer<T> - Interface in io.awspring.cloud.autoconfigure.core

AwsClientProperties - Class in io.awspring.cloud.autoconfigure

Base properties for AWS Service client.

AwsClientProperties() - Constructor for class io.awspring.cloud.autoconfigure.AwsClientProperties

AwsParameterStoreClientCustomizer - Interface in io.awspring.cloud.autoconfigure.config.parameterstore

AwsProperties - Class in io.awspring.cloud.autoconfigure.core

Configuration properties for AWS environment.

AwsProperties() - Constructor for class io.awspring.cloud.autoconfigure.core.AwsProperties

AwsPropertySource<K extends AwsPropertySource,T> - Class in io.awspring.cloud.core.config

Base class for all AWS loaded property sources.

AwsPropertySource(String, T) - Constructor for class io.awspring.cloud.core.config.AwsPropertySource

AwsSecretsManagerClientCustomizer - Interface in io.awspring.cloud.autoconfigure.config.secretsmanager

B

BackPressureHandler - Interface in io.awspring.cloud.sqs.listener

Abstraction to handle backpressure within a PollingMessageSource.

backPressureMode(BackPressureMode) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

BackPressureMode - Enum in io.awspring.cloud.sqs.listener

Configuration for application throughput.

BATCH - Enum constant in enum 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

BackPressureHandler specialization that allows requesting and releasing 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

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.SemaphoreBackPressureHandler.Builder

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.sns.core.MessageAttributeDataTypes

Binary message attribute data type.

BootstrapLoggingHelper - Class in io.awspring.cloud.autoconfigure.config

Utility class for setting up logging in objects registered in BootstrapRegistry.

BUCKET_REDIRECT_HEADER - Static variable in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

bucketKeyEnabled(Boolean) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

build() - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

build() - Method in class io.awspring.cloud.samples.dynamodb.Department.Builder

build() - Method in class io.awspring.cloud.sns.core.SnsNotification.Builder

build() - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes.Builder

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.ContainerOptions.Builder

build() - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder

build() - Method in class io.awspring.cloud.sqs.listener.QueueAttributesResolver.Builder

Build the QueueAttributesResolver instance with the provided settings.

build() - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler.Builder

build() - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder

build(MessageProcessingConfiguration<T>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder

builder() - Static method in class io.awspring.cloud.s3.ObjectMetadata

builder() - Static method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

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.ContainerOptions

builder() - Static method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration

builder() - Static method in class io.awspring.cloud.sqs.listener.QueueAttributesResolver

builder() - Static method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler

builder() - Static method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer

builder(T) - Static method in class io.awspring.cloud.sns.core.SnsNotification

Creates a builder with payload.

Builder() - Constructor for class io.awspring.cloud.s3.ObjectMetadata.Builder

Builder() - Constructor for class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder

Builder() - Constructor for class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

Builder() - Constructor for class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder

Builder() - Constructor for class io.awspring.cloud.sqs.listener.QueueAttributesResolver.Builder

Builder() - Constructor for class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler.Builder

Builder() - Constructor for class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder

Builder(ContainerOptions) - Constructor for class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

C

cacheControl(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

CachingTopicArnResolver - Class in io.awspring.cloud.sns.core

Caching implementation for resolving ARN from topicName.

CachingTopicArnResolver(TopicArnResolver) - Constructor for class io.awspring.cloud.sns.core.CachingTopicArnResolver

changed(EnumerablePropertySource<?>, EnumerablePropertySource<?>) - Method in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

Determines if two property sources are different.

changeTo(int) - Method in interface io.awspring.cloud.sqs.listener.Visibility

Changes the message visibility to the provided value.

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.

checksumAlgorithm(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

checksumAlgorithm(ChecksumAlgorithm) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

clientOverrideConfiguration() - Method in class io.awspring.cloud.core.SpringCloudClientConfiguration

close() - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

close() - Method in class io.awspring.cloud.s3.InMemoryBufferingS3OutputStream

cloudWatchAsyncClient(CloudWatchProperties, AwsClientBuilderConfigurer, ObjectProvider<AwsClientCustomizer<CloudWatchAsyncClientBuilder>>) - Method in class io.awspring.cloud.autoconfigure.metrics.CloudWatchExportAutoConfiguration

cloudWatchConfig(CloudWatchRegistryProperties) - Method in class io.awspring.cloud.autoconfigure.metrics.CloudWatchExportAutoConfiguration

CloudWatchExportAutoConfiguration - Class in io.awspring.cloud.autoconfigure.metrics

Configuration for exporting metrics to CloudWatch.

CloudWatchExportAutoConfiguration() - Constructor for class io.awspring.cloud.autoconfigure.metrics.CloudWatchExportAutoConfiguration

cloudWatchMeterRegistry(CloudWatchConfig, Clock, CloudWatchAsyncClient) - Method in class io.awspring.cloud.autoconfigure.metrics.CloudWatchExportAutoConfiguration

CloudWatchProperties - Class in io.awspring.cloud.autoconfigure.metrics

ConfigurationProperties for configuring CloudWatch client.

CloudWatchProperties() - Constructor for class io.awspring.cloud.autoconfigure.metrics.CloudWatchProperties

CloudWatchRegistryProperties - Class in io.awspring.cloud.autoconfigure.metrics

ConfigurationProperties for configuring CloudWatch metrics export.

CloudWatchRegistryProperties() - Constructor for class io.awspring.cloud.autoconfigure.metrics.CloudWatchRegistryProperties

CompletableFutures - Class in io.awspring.cloud.sqs

Utility methods for using convenient CompletableFuture methods from later JDK versions in Java 8.

completeMultipartUpload(CompleteMultipartUploadRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

componentFactories(Collection<ContainerComponentFactory<T>>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder

componentsTaskExecutor(TaskExecutor) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

CONFIG_PREFIX - Static variable in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreProperties

Configuration prefix.

CONFIG_PREFIX - Static variable in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerProperties

Configuration prefix.

CONFIG_PREFIX - Static variable in class io.awspring.cloud.autoconfigure.core.AwsProperties

Configuration prefix.

ConfigurableContainerComponent - Interface in io.awspring.cloud.sqs.listener

Representation of a MessageListenerContainer component that can be configured using a ContainerOptions instance.

ConfigurationChangeDetector<T extends AwsPropertySource<?,?>> - Class in io.awspring.cloud.autoconfigure.config.reload

This is the superclass of all beans that can listen to changes in the configuration and fire a reload.

ConfigurationChangeDetector(ReloadProperties, ConfigurationUpdateStrategy, ConfigurableEnvironment, Class<T>) - Constructor for class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

ConfigurationUpdateStrategy - Class in io.awspring.cloud.autoconfigure.config.reload

This is the superclass of all named strategies that can be fired when the configuration changes.

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 class io.awspring.cloud.sqs.listener.ContainerOptions

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.adapter.AbstractDelegatingMessageListeningSinkAdapter

configure(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource

configure(Collection<? extends ConfigurableContainerComponent>) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

configure(Consumer<ContainerOptions.Builder>) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory

Allows configuring this factories' ContainerOptions.Builder.

configure(Consumer<ContainerOptions.Builder>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder

configure(Consumer<ContainerOptions.Builder>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer

Returns the ContainerOptions instance for this container.

configure(Consumer<ContainerOptions.Builder>) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder

configure(T) - Method in class io.awspring.cloud.autoconfigure.core.AwsClientBuilderConfigurer

configure(T, AwsClientProperties, AwsClientCustomizer<T>) - Method in class io.awspring.cloud.autoconfigure.core.AwsClientBuilderConfigurer

configure(T, AwsClientProperties, BootstrapContext) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

configureAbstractContainer(AbstractMessageListenerContainer<T>, Endpoint) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory

configureBatchingAcknowledgementProcessor(ContainerOptions, BatchingAcknowledgementProcessor<T>) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory

configureBatchingAckProcessor(ContainerOptions, 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, ContainerOptions.Builder) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory

configureContainerOptions(Endpoint, ContainerOptions.Builder) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory

configureDefaultHandlerMethodFactory(DefaultMessageHandlerMethodFactory) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

configureImmediateAcknowledgementProcessor(ImmediateAcknowledgementProcessor<T>, ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory

configureImmediateProcessor(ImmediateAcknowledgementProcessor<T>, ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory

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>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer

ConfigUtils - Class in io.awspring.cloud.sqs

Utility class for conditional configurations.

confirmSubscription() - Method in interface io.awspring.cloud.sns.handlers.NotificationStatus

containerComponentFactories(Collection<ContainerComponentFactory<T>>) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory.Builder

ContainerComponentFactory<T> - Interface in io.awspring.cloud.sqs.listener

A factory for creating components for the MessageListenerContainer.

ContainerOptions - Class in io.awspring.cloud.sqs.listener

Contains the options to be used by the MessageListenerContainer at runtime.

ContainerOptions(ContainerOptions.Builder) - Constructor for class io.awspring.cloud.sqs.listener.ContainerOptions

ContainerOptions.Builder - Class in io.awspring.cloud.sqs.listener

contentDisposition(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

contentEncoding(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

contentLanguage(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

contentLength() - Method in class io.awspring.cloud.s3.S3Resource

contentType() - Method in class io.awspring.cloud.s3.Jackson2JsonS3ObjectConverter

contentType() - Method in interface io.awspring.cloud.s3.S3ObjectConverter

Supported content type.

contentType() - Method in class io.awspring.cloud.s3.S3Resource

contentType(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

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.

convertAndSend(String, T) - Method in class io.awspring.cloud.sns.core.SnsTemplate

convertAndSend(String, T, Map<String, Object>) - Method in class io.awspring.cloud.sns.core.SnsTemplate

convertAndSend(String, T, Map<String, Object>, MessagePostProcessor) - Method in class io.awspring.cloud.sns.core.SnsTemplate

convertAndSend(String, T, MessagePostProcessor) - Method in class io.awspring.cloud.sns.core.SnsTemplate

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

copy() - Method in class io.awspring.cloud.core.config.AwsPropertySource

Creates a non-initialized copy of the property source.

copy() - Method in class io.awspring.cloud.parameterstore.ParameterStorePropertySource

copy() - Method in class io.awspring.cloud.secretsmanager.SecretsManagerPropertySource

copyObject(CopyObjectRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

create() - Static method in class io.awspring.cloud.sqs.listener.MessageProcessingContext

create(ReloadProperties, ContextRefresher, Optional<RestartEndpoint>) - Static method in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationUpdateStrategy

create(Location, ObjectMetadata) - Method in interface io.awspring.cloud.s3.S3OutputStreamProvider

Creates an OutputStream that writes data to S3.

create(String, String, ObjectMetadata) - Method in class io.awspring.cloud.s3.DiskBufferingS3OutputStreamProvider

create(String, String, ObjectMetadata) - Method in class io.awspring.cloud.s3.InMemoryBufferingS3OutputStreamProvider

create(String, String, ObjectMetadata) - Method in interface io.awspring.cloud.s3.S3OutputStreamProvider

Creates an OutputStream that writes data to S3.

create(String, String, ObjectMetadata) - Method in class io.awspring.cloud.s3.TransferManagerS3OutputStreamProvider

create(String, S3Client, S3OutputStreamProvider) - Static method in class io.awspring.cloud.s3.S3Resource

CREATE - Enum constant in enum 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(ContainerOptions) - 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(ContainerOptions) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory

Create an AcknowledgementProcessor instance.

createAcknowledgementProcessor(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory

createAcknowledgementProcessor(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory

createAdditionalArgumentResolvers() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

createAdditionalArgumentResolvers() - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor

createAndConfigureAcknowledgementExecutor(QueueAttributes) - Method in class io.awspring.cloud.sqs.listener.source.AbstractSqsMessageSource

createAndConfigureImmediateProcessor(ContainerOptions) - 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

createAwsSecretsManagerClient(BootstrapContext) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLocationResolver

createBackPressureHandler() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer

createBatchingProcessorInstance() - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory

createBatchingProcessorInstance() - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory

createBucket(String) - Method in interface io.awspring.cloud.s3.S3Operations

Creates a bucket in S3.

createBucket(String) - Method in class io.awspring.cloud.s3.S3Template

createBucket(CreateBucketRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

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, ContainerOptions) - Method in class io.awspring.cloud.sqs.config.AbstractMessageListenerContainerFactory

createContainerInstance(Endpoint, ContainerOptions) - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory

createContext() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource

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 class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

createCopy() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

createCredentialsProvider(CredentialsProperties) - Static method in class io.awspring.cloud.autoconfigure.core.CredentialsProviderAutoConfiguration

createDefaultMappingJackson2MessageConverter(ObjectMapper) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

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

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

createMessageConversionContext() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter

createMessageListenerInstance(InvocableHandlerMethod) - Method in class io.awspring.cloud.sqs.config.AbstractEndpoint

createMessageProcessingPipeline(ContainerComponentFactory<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer

createMessageSink(ContainerOptions) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory

Create a MessageSink instance.

createMessageSink(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory

createMessageSink(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory

createMessageSource(ContainerOptions) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory

Create a MessageSource instance.

createMessageSource(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory

createMessageSource(ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory

createMessageSource(String, int, ContainerComponentFactory<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer

createMessageSources(ContainerComponentFactory<T>) - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer

createMimeMessage() - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

createMimeMessage(InputStream) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

createMultipartUpload(CreateMultipartUploadRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

createPropertySource(String, boolean, SecretsManagerClient) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerPropertySources

Creates property source for given context.

createPropertySource(String, boolean, SsmClient) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStorePropertySources

Creates property source for given context.

createRegionProvider(RegionProperties) - Static method in class io.awspring.cloud.autoconfigure.core.RegionProviderAutoConfiguration

createSimpleSystemManagementClient(BootstrapContext) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLocationResolver

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

CredentialsProperties - Class in io.awspring.cloud.autoconfigure.core

Properties related to AWS credentials.

CredentialsProperties() - Constructor for class io.awspring.cloud.autoconfigure.core.CredentialsProperties

credentialsProvider() - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProviderAutoConfiguration

CredentialsProviderAutoConfiguration - Class in io.awspring.cloud.autoconfigure.core

EnableAutoConfiguration for AwsCredentialsProvider.

CredentialsProviderAutoConfiguration(CredentialsProperties) - Constructor for class io.awspring.cloud.autoconfigure.core.CredentialsProviderAutoConfiguration

CrossRegionS3Client - Class in io.awspring.cloud.s3.crossregion

CrossRegionS3Client(int, S3ClientBuilder) - Constructor for class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

CrossRegionS3Client(S3ClientBuilder) - Constructor for class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

CrossRegionS3Client.RegionDiscoveryException - Exception in io.awspring.cloud.s3.crossregion

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

DaxProperties - Class in io.awspring.cloud.autoconfigure.dynamodb

Properties used to configure ClusterDaxClient

DaxProperties() - Constructor for class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

deduplicationId(String) - Method in class io.awspring.cloud.sns.core.SnsNotification.Builder

DEFAULT_BUFFER_CAPACITY - Static variable in class io.awspring.cloud.s3.InMemoryBufferingS3OutputStream

DEFAULT_LISTENER_CONTAINER_FACTORY_BEAN_NAME - Static variable in class io.awspring.cloud.sqs.config.EndpointRegistrar

DefaultDynamoDbTableNameResolver - Class in io.awspring.cloud.dynamodb

Simple implementation of DynamoDbTableNameResolver that resolves class simple name to table name.

DefaultDynamoDbTableNameResolver() - Constructor for class io.awspring.cloud.dynamodb.DefaultDynamoDbTableNameResolver

DefaultDynamoDbTableSchemaResolver - Class in io.awspring.cloud.dynamodb

Default implementation with simple cache for TableSchema.

DefaultDynamoDbTableSchemaResolver() - Constructor for class io.awspring.cloud.dynamodb.DefaultDynamoDbTableSchemaResolver

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

defaultSqsListenerContainerFactory(ObjectProvider<SqsAsyncClient>, ObjectProvider<AsyncErrorHandler<Object>>, ObjectProvider<ErrorHandler<Object>>, ObjectProvider<AsyncMessageInterceptor<Object>>, ObjectProvider<MessageInterceptor<Object>>) - Method in class io.awspring.cloud.autoconfigure.sqs.SqsAutoConfiguration

DefaultTopicArnResolver - Class in io.awspring.cloud.sns.core

Default implementation of TopicArnResolver used to determine topic ARN by name.

DefaultTopicArnResolver(SnsClient) - Constructor for class io.awspring.cloud.sns.core.DefaultTopicArnResolver

delete(Key, Class<?>) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Deletes a record for a given Key.

delete(Key, Class<?>) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

delete(T) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Deletes a record for a given Entity.

delete(T) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

deleteBucket(String) - Method in interface io.awspring.cloud.s3.S3Operations

Deletes a S3 bucket.

deleteBucket(String) - Method in class io.awspring.cloud.s3.S3Template

deleteBucket(DeleteBucketRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketAnalyticsConfiguration(DeleteBucketAnalyticsConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketCors(DeleteBucketCorsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketEncryption(DeleteBucketEncryptionRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketIntelligentTieringConfiguration(DeleteBucketIntelligentTieringConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketInventoryConfiguration(DeleteBucketInventoryConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketLifecycle(DeleteBucketLifecycleRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketMetricsConfiguration(DeleteBucketMetricsConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketOwnershipControls(DeleteBucketOwnershipControlsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketPolicy(DeleteBucketPolicyRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketReplication(DeleteBucketReplicationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketTagging(DeleteBucketTaggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteBucketWebsite(DeleteBucketWebsiteRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteObject(String) - Method in interface io.awspring.cloud.s3.S3Operations

Deletes an object from S3 bucket.

deleteObject(String) - Method in class io.awspring.cloud.s3.S3Template

deleteObject(String, String) - Method in interface io.awspring.cloud.s3.S3Operations

Deletes an object from S3 bucket.

deleteObject(String, String) - Method in class io.awspring.cloud.s3.S3Template

deleteObject(DeleteObjectRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteObjects(DeleteObjectsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deleteObjectTagging(DeleteObjectTaggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

deletePublicAccessBlock(DeletePublicAccessBlockRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

Department - Class in io.awspring.cloud.samples.dynamodb

Department() - Constructor for class io.awspring.cloud.samples.dynamodb.Department

Department.Builder - Class in io.awspring.cloud.samples.dynamodb

destroy() - Method in class io.awspring.cloud.ses.SimpleEmailServiceMailSender

detectAnnotationsAndRegisterEndpoints(Object, Class<?>) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

DiskBufferingS3OutputStreamProvider - Class in io.awspring.cloud.s3

Creates DiskBufferingS3OutputStream.

DiskBufferingS3OutputStreamProvider(S3Client, S3ObjectContentTypeResolver) - Constructor for class io.awspring.cloud.s3.DiskBufferingS3OutputStreamProvider

dispose(Object) - Method in class io.awspring.cloud.sqs.LifecycleHandler

Execute the DisposableBean.destroy() method if the provided object is a DisposableBean instance.

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

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

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

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

doResolveArgumentFromNotificationMessage(JsonNode, HttpInputMessage, Class<?>) - Method in class io.awspring.cloud.sns.handlers.AbstractNotificationMessageHandlerMethodArgumentResolver

doResolveArgumentFromNotificationMessage(JsonNode, HttpInputMessage, Class<?>) - Method in class io.awspring.cloud.sns.handlers.NotificationMessageHandlerMethodArgumentResolver

doResolveArgumentFromNotificationMessage(JsonNode, HttpInputMessage, Class<?>) - Method in class io.awspring.cloud.sns.handlers.NotificationStatusHandlerMethodArgumentResolver

doResolveArgumentFromNotificationMessage(JsonNode, HttpInputMessage, Class<?>) - Method in class io.awspring.cloud.sns.handlers.NotificationSubjectHandlerMethodArgumentResolver

doSend(TopicMessageChannel, Message<?>) - Method in class io.awspring.cloud.sns.core.SnsTemplate

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.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

download(String, String) - Method in interface io.awspring.cloud.s3.S3Operations

Downloads object from S3.

download(String, String) - Method in class io.awspring.cloud.s3.S3Template

drain(Duration) - Method in interface io.awspring.cloud.sqs.listener.BackPressureHandler

Attempts to acquire all permits up to the specified timeout.

drain(Duration) - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler

DynamoDbAutoConfiguration - Class in io.awspring.cloud.autoconfigure.dynamodb

Auto-configuration for DynamoDB integration.

DynamoDbAutoConfiguration() - Constructor for class io.awspring.cloud.autoconfigure.dynamodb.DynamoDbAutoConfiguration

dynamoDbEnhancedClient(DynamoDbClient) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DynamoDbAutoConfiguration

DynamoDbOperations - Interface in io.awspring.cloud.dynamodb

Interface for simple DynamoDB template operations.

DynamoDbProperties - Class in io.awspring.cloud.autoconfigure.dynamodb

Properties related to AWS DynamoDB.

DynamoDbProperties() - Constructor for class io.awspring.cloud.autoconfigure.dynamodb.DynamoDbProperties

DynamoDbTableNameResolver - Interface in io.awspring.cloud.dynamodb

Resolves DynamoDB table name from a Class.

DynamoDbTableSchemaResolver - Interface in io.awspring.cloud.dynamodb

Resolving Class and TableName to TableSchema class.

dynamoDBTemplate(DynamoDbEnhancedClient, Optional<DynamoDbTableSchemaResolver>, Optional<DynamoDbTableNameResolver>) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DynamoDbAutoConfiguration

DynamoDbTemplate - Class in io.awspring.cloud.dynamodb

Default implementation of DynamoDbOperations.

DynamoDbTemplate(DynamoDbEnhancedClient) - Constructor for class io.awspring.cloud.dynamodb.DynamoDbTemplate

DynamoDbTemplate(DynamoDbEnhancedClient, DynamoDbTableSchemaResolver, DynamoDbTableNameResolver) - Constructor for class io.awspring.cloud.dynamodb.DynamoDbTemplate

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.

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

entityId(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes.Builder

environment - Variable in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

equals(Object) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataResource

equals(Object) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataResource

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

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.

excludeFilters() - Element in annotation type io.awspring.cloud.test.sqs.SqsTest

A set of exclude filters which can be used to filter beans that would otherwise be added to the application context.

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.

executeCycle() - Method in class io.awspring.cloud.autoconfigure.config.reload.PollingAwsPropertySourceChangeDetector

ExecutingAcknowledgementProcessor<T> - Interface in io.awspring.cloud.sqs.listener.acknowledgement

AcknowledgementProcessor specialization that allows for delegating acknowledgement execution to a AcknowledgementExecutor.

exists() - Method in class io.awspring.cloud.s3.S3Resource

expectedBucketOwner(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

expires(Instant) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

F

factory() - Element in annotation type 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.SqsEndpoint.SqsEndpointBuilder

FAIL - Enum constant in enum io.awspring.cloud.sqs.listener.QueueNotFoundStrategy

Throw an exception and stop application startup if a queue is not found.

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

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

FileController - Class in io.awspring.cloud.samples.s3

An example on how to create file upload to S3.

FileController(S3Operations) - Constructor for class io.awspring.cloud.samples.s3.FileController

first(Function<MessageProcessingConfiguration<T>, MessageProcessingPipeline<T>>) - Static method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingPipelineBuilder

FIXED_HIGH_THROUGHPUT - Enum constant in enum io.awspring.cloud.sqs.listener.BackPressureMode

Set fixed high throughput mode.

fromBuilder(ContainerOptions.Builder) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

fromHeaders(MessageHeaders, Message) - Method in class io.awspring.cloud.sqs.support.converter.SqsHeaderMapper

fromMessagingMessage(Message<?>) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter

fromMessagingMessage(Message<?>) - Method in interface io.awspring.cloud.sqs.support.converter.MessagingMessageConverter

G

get() - Static method in class io.awspring.cloud.sqs.LifecycleHandler

Get the singleton instance for this class.

getAccelerateModeEnabled() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

getAccessKey() - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

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.ContainerOptions

getAcknowledgementMode() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getAcknowledgementOrdering() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

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.AbstractPipelineMessageListenerContainer

getAcknowledgementResultTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getAcknowledgementThreshold() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getAcknowledgmentCallback() - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext

getAcknowledgmentProcessor() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource

getAcl() - Method in class io.awspring.cloud.s3.ObjectMetadata

getAnnotationClass() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

getAnnotationClass() - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor

getBackPressureMode() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getBeanFactory() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

getBucketAccelerateConfiguration(GetBucketAccelerateConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketAcl(GetBucketAclRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketAnalyticsConfiguration(GetBucketAnalyticsConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketCors(GetBucketCorsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketEncryption(GetBucketEncryptionRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketIntelligentTieringConfiguration(GetBucketIntelligentTieringConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketInventoryConfiguration(GetBucketInventoryConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketKeyEnabled() - Method in class io.awspring.cloud.s3.ObjectMetadata

getBucketLifecycleConfiguration(GetBucketLifecycleConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketLocation(GetBucketLocationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketLogging(GetBucketLoggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketMetricsConfiguration(GetBucketMetricsConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketNotificationConfiguration(GetBucketNotificationConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketOwnershipControls(GetBucketOwnershipControlsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketPolicy(GetBucketPolicyRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketPolicyStatus(GetBucketPolicyStatusRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketReplication(GetBucketReplicationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketRequestPayment(GetBucketRequestPaymentRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketTagging(GetBucketTaggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketVersioning(GetBucketVersioningRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getBucketWebsite(GetBucketWebsiteRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getCacheControl() - Method in class io.awspring.cloud.s3.ObjectMetadata

getChecksumAlgorithm() - Method in class io.awspring.cloud.s3.ObjectMetadata

getChecksumValidationEnabled() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

getChunkedEncodingEnabled() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

getClient(Region) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getClusterUpdateIntervalMillis() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getComponentIncludes() - Method in class io.awspring.cloud.test.sqs.SqsTypeExcludeFilter

getComponentsTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer

getComponentsTaskExecutor() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getConfigurableBeanFactory() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

getConnectionTtlMillis() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getConnectTimeoutMillis() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

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

getContentDisposition() - Method in class io.awspring.cloud.s3.ObjectMetadata

getContentEncoding() - Method in class io.awspring.cloud.s3.ObjectMetadata

getContentLanguage() - Method in class io.awspring.cloud.s3.ObjectMetadata

getContentType() - Method in class io.awspring.cloud.s3.ObjectMetadata

getContext() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataResource

Returns context which is equal to Secret Manager secret name.

getContext() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataResource

Returns context which is equal to Secret Manager secret name.

getCustomContexts(String) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

getDax() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DynamoDbProperties

getDeduplicationId() - Method in class io.awspring.cloud.sns.core.SnsNotification

getDefaultComponentFactories() - Method in class io.awspring.cloud.sqs.listener.AbstractPipelineMessageListenerContainer

getDefaultComponentFactories() - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer

getDefaultHeaderMapper() - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter

getDefaultHeaderMapper() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter

getDefaultsMode() - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

getDelegate() - Method in class io.awspring.cloud.sqs.listener.sink.adapter.AbstractDelegatingMessageListeningSinkAdapter

getDepartmentId() - Method in class io.awspring.cloud.samples.dynamodb.Department

getDescription() - Method in class io.awspring.cloud.s3.S3Resource

getDualstackEnabled() - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

getEmailService() - Method in class io.awspring.cloud.ses.SimpleEmailServiceMailSender

getEmployeeNumber() - Method in class io.awspring.cloud.samples.dynamodb.Department

getEndpoint() - Method in class io.awspring.cloud.autoconfigure.AwsClientProperties

getEndpoint() - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

getEndpointId(String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

getEndpointRefreshTimeoutMillis() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getEntityId() - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

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

getExpectedBucketOwner() - Method in class io.awspring.cloud.s3.ObjectMetadata

getExpires() - Method in class io.awspring.cloud.s3.ObjectMetadata

getFailedAcknowledgementMessages() - Method in exception io.awspring.cloud.sqs.listener.acknowledgement.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.

getFailedMessages() - Method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException

Return the messages which listener execution failed.

getFile() - Method in class io.awspring.cloud.s3.S3Resource

getFipsEnabled() - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

getFollowSymbolicLinks() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties.S3UploadDirectoryProperties

getGeneratedIdPrefix() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

getGeneratedIdPrefix() - Method in class io.awspring.cloud.sqs.annotation.SqsListenerAnnotationBeanPostProcessor

getGrantFullControl() - Method in class io.awspring.cloud.s3.ObjectMetadata

getGrantRead() - Method in class io.awspring.cloud.s3.ObjectMetadata

getGrantReadACP() - Method in class io.awspring.cloud.s3.ObjectMetadata

getGrantWriteACP() - Method in class io.awspring.cloud.s3.ObjectMetadata

getGroupId() - Method in class io.awspring.cloud.sns.core.SnsNotification

getHeader(Collection<Message<U>>, 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.

getHeaders() - Method in class io.awspring.cloud.sns.core.SnsNotification

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 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.SemaphoreBackPressureHandler

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].

getIdleTimeoutMillis() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getInputStream() - Method in class io.awspring.cloud.s3.S3Resource

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

getJavaMailProperties() - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

Allow Map access to the JavaMail properties of this sender, with the option to add or override specific entries.

getListener() - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties

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.ContainerOptions

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.

getMaxConcurrency() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getMaxConcurrency() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

getMaxDepth() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties.S3UploadDirectoryProperties

getMaxInflightMessagesPerQueue() - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties.Listener

getMaxInflightMessagesPerQueue() - Method in class io.awspring.cloud.sqs.config.SqsEndpoint

The maximum number of inflight messages each queue in this endpoint can process simultaneously.

getMaxInFlightMessagesPerQueue() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

Return the maximum allowed number of inflight messages for each queue.

getMaxMessagesPerPoll() - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties.Listener

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.ContainerOptions

Return the number of messages that should be returned per poll.

getMaxPendingConnectionAcquires() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getMaxPrice() - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

getMaxWaitForRestart() - Method in class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

getMessageAttributeNames() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getMessageConversionContext() - Method in class io.awspring.cloud.sqs.listener.source.AbstractMessageConvertingMessageSource

getMessageConverter() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getMessageConverterConsumer() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar

Get the message converters list consumer.

getMessageGroupingFunction() - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor

getMessageHandlerMethodFactory() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar

Return the MessageHandlerMethodFactory to be used to create MessageHandler instances for the Endpoints.

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

getMessageSystemAttributeNames() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

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.ContainerOptions

getMetadata() - Method in class io.awspring.cloud.s3.ObjectMetadata

getMethodArgumentResolversConsumer() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar

Get the method argument resolvers list consumer.

getMinimumPartSizeInBytes() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

getName() - Method in class io.awspring.cloud.autoconfigure.core.Profile

getNamespace() - Method in class io.awspring.cloud.autoconfigure.metrics.CloudWatchRegistryProperties

getNotificationHandlerMethodArgumentResolver(SnsClient) - Static method in class io.awspring.cloud.sns.configuration.NotificationHandlerMethodArgumentResolverConfigurationUtils

getObject(GetObjectRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObject(GetObjectRequest, Path) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObject(GetObjectRequest, ResponseTransformer<GetObjectResponse, ReturnT>) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectAcl(GetObjectAclRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectAsBytes(GetObjectRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectAttributes(GetObjectAttributesRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectLegalHold(GetObjectLegalHoldRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectLockConfiguration(GetObjectLockConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectLockLegalHoldStatus() - Method in class io.awspring.cloud.s3.ObjectMetadata

getObjectLockMode() - Method in class io.awspring.cloud.s3.ObjectMetadata

getObjectLockRetainUntilDate() - Method in class io.awspring.cloud.s3.ObjectMetadata

getObjectMapper() - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar

Get the object mapper used to deserialize payloads.

getObjectRetention(GetObjectRetentionRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectTagging(GetObjectTaggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectTorrent(GetObjectTorrentRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectTorrent(GetObjectTorrentRequest, Path) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectTorrent(GetObjectTorrentRequest, ResponseTransformer<GetObjectTorrentResponse, ReturnT>) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getObjectTorrentAsBytes(GetObjectTorrentRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

getOpeningDate() - Method in class io.awspring.cloud.samples.dynamodb.Department

getOriginationNumber() - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

getOutputStream() - Method in class io.awspring.cloud.s3.S3Resource

getPath() - Method in class io.awspring.cloud.autoconfigure.core.Profile

getPath() - Method in exception io.awspring.cloud.s3.UploadFailedException

getPathStyleAccessEnabled() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

getPayload() - Method in class io.awspring.cloud.sns.core.SnsNotification

getPayloadToConvert(S) - Method in class io.awspring.cloud.sqs.support.converter.AbstractMessagingMessageConverter

getPayloadToConvert(Message) - Method in class io.awspring.cloud.sqs.support.converter.SqsMessagingMessageConverter

getPeriod() - Method in class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

getPermitAcquireTimeout() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

Return the maximum time the polling thread should wait for permits.

getPollingEndpointName() - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource

getPollTimeout() - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties.Listener

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.ContainerOptions

Return the timeout for polling messages for this endpoint.

getPrefix() - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

getPrefix() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLocationResolver

getPrefix() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLocationResolver

getProfile() - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

getProfile() - Method in class io.awspring.cloud.autoconfigure.core.RegionProperties

getProperties(Class<?>) - Method in class io.awspring.cloud.test.sqs.SqsTestContextBootstrapper

getProperty(String) - Method in class io.awspring.cloud.parameterstore.ParameterStorePropertySource

getProperty(String) - Method in class io.awspring.cloud.secretsmanager.SecretsManagerPropertySource

getPropertyNames() - Method in class io.awspring.cloud.parameterstore.ParameterStorePropertySource

getPropertyNames() - Method in class io.awspring.cloud.secretsmanager.SecretsManagerPropertySource

getPropertySourceClass() - Method in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

getPropertySources() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataResource

getPropertySources() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataResource

getPublicAccessBlock(GetPublicAccessBlockRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

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.ContainerOptions

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.ContainerOptions

getQueueUrl() - Method in exception io.awspring.cloud.sqs.listener.acknowledgement.SqsAcknowledgementException

Return the url for the queue from which the messages were polled from.

getQueueUrl() - Method in class io.awspring.cloud.sqs.listener.QueueAttributes

Return the queue url.

getReadRetries() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getRecursive() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties.S3UploadDirectoryProperties

getRegion() - Method in class io.awspring.cloud.autoconfigure.AwsClientProperties

getRegion() - Method in class io.awspring.cloud.core.region.StaticRegionProvider

Return the configured Region configured at construction time.

getReload() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreProperties

getReload() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerProperties

getRequestPayer() - Method in class io.awspring.cloud.s3.ObjectMetadata

getRequestTimeoutMillis() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getSecretKey() - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

getSenderID() - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

getServerSideEncryption() - Method in class io.awspring.cloud.s3.ObjectMetadata

getSession() - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

Return the JavaMail Session, lazily initializing it if hasn't been specified explicitly.

getShutdownTimeout() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

getSkipHostNameVerification() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getSmsType() - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

getSqsAsyncClient() - Method in class io.awspring.cloud.sqs.support.converter.SqsMessageConversionContext

getSqsAsyncClientInstance() - Method in class io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory

getSseCustomerAlgorithm() - Method in class io.awspring.cloud.s3.ObjectMetadata

getSseCustomerKey() - Method in class io.awspring.cloud.s3.ObjectMetadata

getSseCustomerKeyMD5() - Method in class io.awspring.cloud.s3.ObjectMetadata

getSsekmsEncryptionContext() - Method in class io.awspring.cloud.s3.ObjectMetadata

getSsekmsKeyId() - Method in class io.awspring.cloud.s3.ObjectMetadata

getStatic() - Method in class io.awspring.cloud.autoconfigure.core.RegionProperties

getStorageClass() - Method in class io.awspring.cloud.s3.ObjectMetadata

getStrategy() - Method in class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

getSubject() - Method in class io.awspring.cloud.sns.core.SnsNotification

getTagging() - Method in class io.awspring.cloud.s3.ObjectMetadata

getTargetThroughputInGbps() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

getTemplateId() - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

getTransferManager() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

getUploadDirectory() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

getUrl() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

getURL() - Method in class io.awspring.cloud.s3.S3Resource

getUseArnRegionEnabled() - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

getUserId() - Method in class io.awspring.cloud.samples.dynamodb.Department

getValueResolver() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

getWebsiteRedirectLocation() - Method in class io.awspring.cloud.s3.ObjectMetadata

getWriteRetries() - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

grantFullControl(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

grantRead(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

grantReadACP(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

grantWriteACP(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

groupId(String) - Method in class io.awspring.cloud.sns.core.SnsNotification.Builder

H

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(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.

handleCompose(CompletableFuture<T>, BiFunction<? super T, Throwable, ? extends CompletableFuture<U>>) - 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.

handleNotificationMessage(String, String) - Method in class io.awspring.cloud.sns.sample.NotificationMappingController

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.

handleSubscriptionMessage(NotificationStatus) - Method in class io.awspring.cloud.sns.sample.NotificationMappingController

handleUnsubscribeMessage(NotificationStatus) - Method in class io.awspring.cloud.sns.sample.NotificationMappingController

hashCode() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataResource

hashCode() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataResource

hasListenerException(Throwable) - Static method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException

headBucket(HeadBucketRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

header(String, Object) - Method in class io.awspring.cloud.sns.core.SnsNotification.Builder

headers(Map<String, Object>) - Method in class io.awspring.cloud.sns.core.SnsNotification.Builder

headObject(HeadObjectRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

httpClient() - Method in interface io.awspring.cloud.autoconfigure.core.AwsClientCustomizer

httpClientBuilder() - Method in interface io.awspring.cloud.autoconfigure.core.AwsClientCustomizer

I

id() - Element in annotation type 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.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

includeFilters() - Element in annotation type io.awspring.cloud.test.sqs.SqsTest

A set of include filters which can be used to add otherwise filtered beans to the application context.

InfrastructureApp - Class in io.awspring.cloud.samples.infrastructure

InfrastructureApp() - Constructor for class io.awspring.cloud.samples.infrastructure.InfrastructureApp

InfrastructureStack - Class in io.awspring.cloud.samples.infrastructure

InfrastructureStack(Construct, String) - Constructor for class io.awspring.cloud.samples.infrastructure.InfrastructureStack

InfrastructureStack(Construct, String, StackProps) - Constructor for class io.awspring.cloud.samples.infrastructure.InfrastructureStack

init() - Method in class io.awspring.cloud.core.config.AwsPropertySource

Initializes & fetches properties.

init() - Method in class io.awspring.cloud.parameterstore.ParameterStorePropertySource

init() - Method in class io.awspring.cloud.secretsmanager.SecretsManagerPropertySource

Loads properties from the Secrets Manager secret.

initializeHandlerMethodFactory() - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

InMemoryBufferingS3OutputStream - Class in io.awspring.cloud.s3

S3OutputStream implementation that buffers content to an internal ByteArrayOutputStream and streams the content as a MultiPartUpload as the buffer fills up.

InMemoryBufferingS3OutputStreamProvider - Class in io.awspring.cloud.s3

InMemoryBufferingS3OutputStreamProvider(S3Client, S3ObjectContentTypeResolver) - Constructor for class io.awspring.cloud.s3.InMemoryBufferingS3OutputStreamProvider

InMemoryBufferingS3OutputStreamProvider(S3Client, S3ObjectContentTypeResolver, DataSize) - Constructor for class io.awspring.cloud.s3.InMemoryBufferingS3OutputStreamProvider

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.

interceptors(Collection<AsyncMessageInterceptor<T>>) - Method in class io.awspring.cloud.sqs.listener.pipeline.MessageProcessingConfiguration.Builder

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.autoconfigure - package io.awspring.cloud.autoconfigure

Auto-configurations for AWS services integrations.

io.awspring.cloud.autoconfigure.config - package io.awspring.cloud.autoconfigure.config

ConfigDataLoader implementations for AWS services.

io.awspring.cloud.autoconfigure.config.parameterstore - package io.awspring.cloud.autoconfigure.config.parameterstore

ConfigDataLoader implementation for AWS Parameter Store.

io.awspring.cloud.autoconfigure.config.reload - package io.awspring.cloud.autoconfigure.config.reload

io.awspring.cloud.autoconfigure.config.secretsmanager - package io.awspring.cloud.autoconfigure.config.secretsmanager

ConfigDataLoader implementation for AWS Secrets Manager.

io.awspring.cloud.autoconfigure.core - package io.awspring.cloud.autoconfigure.core

Auto-configurations for core Spring Cloud AWS components - AwsCredentialsProvider and AwsRegionProvider.

io.awspring.cloud.autoconfigure.dynamodb - package io.awspring.cloud.autoconfigure.dynamodb

Auto-configuration for DynamoDB integration.

io.awspring.cloud.autoconfigure.metrics - package io.awspring.cloud.autoconfigure.metrics

Auto-configuration for CloudWatch integration.

io.awspring.cloud.autoconfigure.s3 - package io.awspring.cloud.autoconfigure.s3

Auto-configuration for S3 integrations.

io.awspring.cloud.autoconfigure.s3.properties - package io.awspring.cloud.autoconfigure.s3.properties

Properties for auto-configuration

io.awspring.cloud.autoconfigure.ses - package io.awspring.cloud.autoconfigure.ses

Auto-configuration for Amazon SES (Simple Email Service) integrations.

io.awspring.cloud.autoconfigure.sns - package io.awspring.cloud.autoconfigure.sns

Auto-configuration for Amazon SNS (Simple Notification Service) integrations.

io.awspring.cloud.autoconfigure.sqs - package io.awspring.cloud.autoconfigure.sqs

Auto-configuration for Amazon SQS (Simple Queue Service) integrations.

io.awspring.cloud.core - package io.awspring.cloud.core

Common infrastructure for all Spring Cloud AWS modules.

io.awspring.cloud.core.config - package io.awspring.cloud.core.config

io.awspring.cloud.core.region - package io.awspring.cloud.core.region

Utilities for handling AWS region selection.

io.awspring.cloud.dynamodb - package io.awspring.cloud.dynamodb

io.awspring.cloud.parameterstore - package io.awspring.cloud.parameterstore

Integration with AWS Parameter Store.

io.awspring.cloud.s3 - package io.awspring.cloud.s3

S3 integration.

io.awspring.cloud.s3.codegen - package io.awspring.cloud.s3.codegen

io.awspring.cloud.s3.crossregion - package io.awspring.cloud.s3.crossregion

Generated cross-region S3 client.

io.awspring.cloud.samples.dynamodb - package io.awspring.cloud.samples.dynamodb

io.awspring.cloud.samples.infrastructure - package io.awspring.cloud.samples.infrastructure

io.awspring.cloud.samples.parameterstore - package io.awspring.cloud.samples.parameterstore

io.awspring.cloud.samples.s3 - package io.awspring.cloud.samples.s3

io.awspring.cloud.samples.secretsmanager - package io.awspring.cloud.samples.secretsmanager

io.awspring.cloud.samples.ses - package io.awspring.cloud.samples.ses

io.awspring.cloud.secretsmanager - package io.awspring.cloud.secretsmanager

Integration with AWS Secrets Manager.

io.awspring.cloud.ses - package io.awspring.cloud.ses

Integration with AWS SES (Simple Email Service).

io.awspring.cloud.sns - package io.awspring.cloud.sns

Integration with AWS SNS (Simple Notification Service).

io.awspring.cloud.sns.annotation.endpoint - package io.awspring.cloud.sns.annotation.endpoint

Convenience annotations serving as a replacement for RequestMapping for SNS HTTP endpoints.

io.awspring.cloud.sns.annotation.handlers - package io.awspring.cloud.sns.annotation.handlers

Spring Web method argument handlers for Sns integration.

io.awspring.cloud.sns.configuration - package io.awspring.cloud.sns.configuration

Sns integration configuration helpers.

io.awspring.cloud.sns.core - package io.awspring.cloud.sns.core

Sns integration core.

io.awspring.cloud.sns.handlers - package io.awspring.cloud.sns.handlers

Method argument handlers for SNS integration annotations from io.awspring.cloud.sns.annotation.handlers package.

io.awspring.cloud.sns.sample - package io.awspring.cloud.sns.sample

io.awspring.cloud.sns.sms - package io.awspring.cloud.sns.sms

Sending SMS via SNS integration.

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.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.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.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.resolver - package io.awspring.cloud.sqs.support.resolver

Components for resolving method arguments in listener methods.

io.awspring.cloud.test.sqs - package io.awspring.cloud.test.sqs

isEnabled() - Method in class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

isInstanceProfile() - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

isInstanceProfile() - Method in class io.awspring.cloud.autoconfigure.core.RegionProperties

isOptional() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataResource

If application startup should fail when secret cannot be loaded or does not exist.

isOptional() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataResource

If application startup should fail when secret cannot be loaded or does not exist.

isResolvable(ConfigDataLocationResolverContext, ConfigDataLocation) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

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.

isStatic() - Method in class io.awspring.cloud.autoconfigure.core.RegionProperties

J

Jackson2JsonS3ObjectConverter - Class in io.awspring.cloud.s3

Jackson based implementation of S3ObjectConverter.

Jackson2JsonS3ObjectConverter(ObjectMapper) - Constructor for class io.awspring.cloud.s3.Jackson2JsonS3ObjectConverter

javaMailSender(SesClient) - Method in class io.awspring.cloud.autoconfigure.ses.SesAutoConfiguration

L

lastModified() - Method in class io.awspring.cloud.s3.S3Resource

LifecycleHandler - Class in io.awspring.cloud.sqs

Handler for lifecycle methods.

listBucketAnalyticsConfigurations(ListBucketAnalyticsConfigurationsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listBucketIntelligentTieringConfigurations(ListBucketIntelligentTieringConfigurationsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listBucketInventoryConfigurations(ListBucketInventoryConfigurationsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listBucketMetricsConfigurations(ListBucketMetricsConfigurationsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listBuckets(ListBucketsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

Listener() - Constructor for class io.awspring.cloud.autoconfigure.sqs.SqsProperties.Listener

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.ContainerOptions.Builder

ListenerMode - Enum in io.awspring.cloud.sqs.listener

Configure the delivery strategy to be used by a MessageListenerContainer.

listeners() - Element in annotation type io.awspring.cloud.test.sqs.SqsTest

Specifies the listeners to test.

listMultipartUploads(ListMultipartUploadsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listMultipartUploadsPaginator(ListMultipartUploadsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listObjects(ListObjectsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listObjectsV2(ListObjectsV2Request) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listObjectsV2Paginator(ListObjectsV2Request) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listObjectVersions(ListObjectVersionsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listObjectVersionsPaginator(ListObjectVersionsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listParts(ListPartsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

listPartsPaginator(ListPartsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

load(ConfigDataLoaderContext, ParameterStoreConfigDataResource) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLoader

load(ConfigDataLoaderContext, SecretsManagerConfigDataResource) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLoader

load(Key, Class<T>) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Loads entity for a given Key.

load(Key, Class<T>) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

loadAwsProperties(Binder) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

loadCredentialsProperties(Binder) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

loadProperties(Binder) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLocationResolver

loadProperties(Binder) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLocationResolver

loadRegionProperties(Binder) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

locateMapPropertySources(ConfigurableEnvironment) - Method in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

Returns a list of property sources that are instance of ConfigurationChangeDetector.

log - Variable in class io.awspring.cloud.autoconfigure.config.reload.PollingAwsPropertySourceChangeDetector

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

MailSendingApplication - Class in io.awspring.cloud.samples.ses

MailSendingApplication() - Constructor for class io.awspring.cloud.samples.ses.MailSendingApplication

main(String[]) - Static method in class io.awspring.cloud.s3.codegen.AbstractCrossRegionS3ClientGenerator

main(String[]) - Static method in class io.awspring.cloud.samples.dynamodb.SpringDynamoDbSample

main(String[]) - Static method in class io.awspring.cloud.samples.infrastructure.InfrastructureApp

main(String[]) - Static method in class io.awspring.cloud.samples.parameterstore.SpringCloudAwsParameterStoreSample

main(String[]) - Static method in class io.awspring.cloud.samples.s3.SpringCloudAwsS3Sample

main(String[]) - Static method in class io.awspring.cloud.samples.secretsmanager.App

main(String[]) - Static method in class io.awspring.cloud.samples.ses.MailSendingApplication

main(String[]) - Static method in class io.awspring.cloud.sns.sample.SpringSNSSample

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 io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode

Messages will not be acknowledged automatically by the container.

maxInflightMessagesPerQueue() - Element in annotation type io.awspring.cloud.sqs.annotation.SqsListener

The maximum number of inflight messages that should be processed simultaneously for each queue declared in this annotation.

maxInflightMessagesPerQueue(int) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

Set the maximum allowed number of inflight messages for each queue.

maxInflightMessagesPerQueue(Integer) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder

maxMessagesPerPoll() - Element in annotation type io.awspring.cloud.sqs.annotation.SqsListener

The maximum amount of time to wait for a poll to SQS.

maxMessagesPerPoll(int) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

Set the number of messages that should be returned per poll.

maxMessagesPerPoll(Integer) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder

maxPrice(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes.Builder

MESSAGE_DEDUPLICATION_ID_HEADER - Static variable in class io.awspring.cloud.sns.core.SnsHeaders

Message Deduplication id for SNS message.

MESSAGE_GROUP_ID_HEADER - Static variable in class io.awspring.cloud.sns.core.SnsHeaders

Message group id for SNS message (applies only to FIFO topic).

MessageAttributeDataTypes - Class in io.awspring.cloud.sns.core

Helper class used for conversion between MessageAttributeValue and Java types.

messageAttributeNames(Collection<String>) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

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.ContainerOptions.Builder

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

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

MessageHeaderUtils - Class in io.awspring.cloud.sqs

Utility class for extracting MessageHeaders from a Message.

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.

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.ContainerOptions.Builder

messageVisibility(Integer) - Method in class io.awspring.cloud.sqs.config.SqsEndpoint.SqsEndpointBuilder

messageVisibility(Duration) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

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 type io.awspring.cloud.sqs.annotation.SqsListener

The message visibility to be applied to messages received from the provided queues.

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(InvocableHandlerMethod) - Constructor for class io.awspring.cloud.sqs.listener.adapter.MessagingMessageListenerAdapter

metadata() - Method in class io.awspring.cloud.s3.S3Resource

metadata(String, String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

micrometerClock() - Method in class io.awspring.cloud.autoconfigure.metrics.CloudWatchExportAutoConfiguration

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

NOTIFICATION_SUBJECT_HEADER - Static variable in class io.awspring.cloud.sns.core.SnsHeaders

Notification subject.

NotificationHandlerMethodArgumentResolverConfigurationUtils - Class in io.awspring.cloud.sns.configuration

Simple util class that is used to create handlers for Http/s notification support.

NotificationMappingController - Class in io.awspring.cloud.sns.sample

NotificationMappingController() - Constructor for class io.awspring.cloud.sns.sample.NotificationMappingController

NotificationMessage - Annotation Type in io.awspring.cloud.sns.annotation.handlers

Annotation that is used to map SNS notification value to a variable that is annotated.

NotificationMessageHandlerMethodArgumentResolver - Class in io.awspring.cloud.sns.handlers

Handles conversion of SNS notification value to a variable that is annotated with NotificationMessage.

NotificationMessageHandlerMethodArgumentResolver() - Constructor for class io.awspring.cloud.sns.handlers.NotificationMessageHandlerMethodArgumentResolver

NotificationMessageHandlerMethodArgumentResolver(List<HttpMessageConverter<?>>) - Constructor for class io.awspring.cloud.sns.handlers.NotificationMessageHandlerMethodArgumentResolver

NotificationMessageMapping - Annotation Type in io.awspring.cloud.sns.annotation.endpoint

Spring Web MVC request mapping that supports Amazon SNS HTTP endpoints using the Spring Controller model.

NotificationStatus - Interface in io.awspring.cloud.sns.handlers

Interface used for confirming Subscription/Unsubscription.

NotificationStatusHandlerMethodArgumentResolver - Class in io.awspring.cloud.sns.handlers

Handles Subscription and Unsubscription events by transforming them to NotificationStatus which can be used to confirm Subscriptions/Subscriptions.

NotificationStatusHandlerMethodArgumentResolver(SnsClient) - Constructor for class io.awspring.cloud.sns.handlers.NotificationStatusHandlerMethodArgumentResolver

NotificationSubject - Annotation Type in io.awspring.cloud.sns.annotation.handlers

Annotation that is used to map SNS subject value to a variable that is annotated.

NotificationSubjectHandlerMethodArgumentResolver - Class in io.awspring.cloud.sns.handlers

Handles conversion of SNS subject value to a variable that is annotated with NotificationSubject.

NotificationSubjectHandlerMethodArgumentResolver() - Constructor for class io.awspring.cloud.sns.handlers.NotificationSubjectHandlerMethodArgumentResolver

NotificationSubscriptionMapping - Annotation Type in io.awspring.cloud.sns.annotation.endpoint

Spring Web MVC request mapping that supports Amazon SNS HTTP endpoint subscriptions using the Spring Controller model.

NotificationUnsubscribeConfirmationMapping - Annotation Type in io.awspring.cloud.sns.annotation.endpoint

Spring Web MVC request mapping that supports Amazon SNS HTTP endpoint subscriptions using the Spring Controller model.

NUMBER - Static variable in class io.awspring.cloud.sns.core.MessageAttributeDataTypes

Number message attribute data type.

O

objectLockLegalHoldStatus(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

objectLockLegalHoldStatus(ObjectLockLegalHoldStatus) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

objectLockMode(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

objectLockMode(ObjectLockMode) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

objectLockRetainUntilDate(Instant) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

objectMapperCustomizer(ObjectProvider<ObjectMapper>) - Method in class io.awspring.cloud.autoconfigure.sqs.SqsAutoConfiguration

ObjectMetadata - Class in io.awspring.cloud.s3

Container for S3 Object Metadata.

ObjectMetadata.Builder - Class in io.awspring.cloud.s3

ObjectStorageController - Class in io.awspring.cloud.samples.s3

Stores regular Java objects as S3 files.

ObjectStorageController(S3Template) - Constructor for class io.awspring.cloud.samples.s3.ObjectStorageController

of(T) - Static method in class io.awspring.cloud.sns.core.SnsNotification

Creates notification from payload.

ofMissingHeader(S3Exception) - Static method in exception io.awspring.cloud.s3.crossregion.CrossRegionS3Client.RegionDiscoveryException

ON_SUCCESS - Enum constant in enum io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode

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.

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 io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering

Acknowledgements will be executed sequentially.

ORDERED_BY_GROUP - Enum constant in enum 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

originationNumber(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes.Builder

overrideConfiguration() - Method in interface io.awspring.cloud.autoconfigure.core.AwsClientCustomizer

P

PARALLEL - Enum constant in enum io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering

Acknowledgements will be executed in parallel.

ParameterStoreConfigDataLoader - Class in io.awspring.cloud.autoconfigure.config.parameterstore

ConfigDataLoader for AWS Parameter Store.

ParameterStoreConfigDataLoader(DeferredLogFactory) - Constructor for class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLoader

ParameterStoreConfigDataLocationResolver - Class in io.awspring.cloud.autoconfigure.config.parameterstore

ParameterStoreConfigDataLocationResolver(DeferredLogFactory) - Constructor for class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLocationResolver

ParameterStoreConfigDataResource - Class in io.awspring.cloud.autoconfigure.config.parameterstore

Config data resource for AWS System Manager Management integration.

ParameterStoreConfigDataResource(String, boolean, ParameterStorePropertySources) - Constructor for class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataResource

parameterStoreConfigurationUpdateStrategy(ParameterStoreProperties, Optional<RestartEndpoint>, ContextRefresher) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreReloadAutoConfiguration

ParameterStoreKeysMissingException - Exception in io.awspring.cloud.autoconfigure.config.parameterstore

Thrown when configuration provided to ConfigDataLoader is missing parameter store keys, for example `spring.config.import=aws-parameterstore:`.

ParameterStoreMissingKeysFailureAnalyzer - Class in io.awspring.cloud.autoconfigure.config.parameterstore

An AbstractFailureAnalyzer that performs analysis of a Parameter Store configuration failure caused by not providing a Parameter Store key to `spring.config.import` property.

ParameterStoreMissingKeysFailureAnalyzer() - Constructor for class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreMissingKeysFailureAnalyzer

parameterStorePollingAwsPropertySourceChangeDetector(ParameterStoreProperties, ConfigurationUpdateStrategy, TaskSchedulerWrapper<TaskScheduler>, ConfigurableEnvironment) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreReloadAutoConfiguration

ParameterStoreProperties - Class in io.awspring.cloud.autoconfigure.config.parameterstore

Configuration properties for the AWS Parameter Store integration.

ParameterStoreProperties() - Constructor for class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreProperties

ParameterStorePropertySource - Class in io.awspring.cloud.parameterstore

Recursively retrieves all parameters under the given context / path with decryption from the AWS Parameter Store using the provided SSM client.

ParameterStorePropertySource(String, SsmClient) - Constructor for class io.awspring.cloud.parameterstore.ParameterStorePropertySource

ParameterStorePropertySources - Class in io.awspring.cloud.autoconfigure.config.parameterstore

ParameterStorePropertySources() - Constructor for class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStorePropertySources

ParameterStoreReloadAutoConfiguration - Class in io.awspring.cloud.autoconfigure.config.parameterstore

Auto-Configuration for reloading properties from Parameter Store.

ParameterStoreReloadAutoConfiguration() - Constructor for class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreReloadAutoConfiguration

path() - Element in annotation type io.awspring.cloud.sns.annotation.endpoint.NotificationMessageMapping

path() - Element in annotation type io.awspring.cloud.sns.annotation.endpoint.NotificationSubscriptionMapping

path() - Element in annotation type io.awspring.cloud.sns.annotation.endpoint.NotificationUnsubscribeConfirmationMapping

permitAcquireTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

Set the maximum time the polling thread should wait for permits.

PollingAwsPropertySourceChangeDetector<T extends AwsPropertySource<?,?>> - Class in io.awspring.cloud.autoconfigure.config.reload

Configuration change detector that checks for changed configuration on a scheduled basis.

PollingAwsPropertySourceChangeDetector(ReloadProperties, Class<T>, ConfigurationUpdateStrategy, TaskScheduler, ConfigurableEnvironment) - Constructor for class io.awspring.cloud.autoconfigure.config.reload.PollingAwsPropertySourceChangeDetector

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.ContainerOptions.Builder

Set the timeout for polling messages for this endpoint.

pollTimeoutSeconds() - Element in annotation type 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

postProcessBeanFactory(ConfigurableListableBeanFactory) - Method in class io.awspring.cloud.s3.S3ProtocolResolver

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLocationResolver

AWS ParameterStore Config Data prefix.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLocationResolver

AWS Secrets Manager Config Data prefix.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

The prefix used for AWS credentials related properties.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.core.RegionProperties

The prefix used for AWS region related properties.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.dynamodb.DynamoDbProperties

The prefix used for AWS credentials related properties.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

The prefix used for S3 related properties.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.ses.SesProperties

The prefix used for AWS credentials related properties.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.sns.SnsProperties

The prefix used for AWS SNS configuration.

PREFIX - Static variable in class io.awspring.cloud.autoconfigure.sqs.SqsProperties

The prefix used for AWS SQS configuration.

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

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

Profile - Class in io.awspring.cloud.autoconfigure.core

Properties related to AWS Profile.

Profile() - Constructor for class io.awspring.cloud.autoconfigure.core.Profile

PROMOTIONAL - Enum constant in enum io.awspring.cloud.sns.sms.SmsType

Non-critical messages, such as marketing messages.

properties - Variable in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

properties() - Element in annotation type io.awspring.cloud.test.sqs.SqsTest

Properties in form key=value that should be added to the Spring Environment before the test runs.

PropertiesS3ObjectContentTypeResolver - Class in io.awspring.cloud.s3

Resolves content type for S3 object from a properties file.

PropertiesS3ObjectContentTypeResolver() - Constructor for class io.awspring.cloud.s3.PropertiesS3ObjectContentTypeResolver

PropertiesS3ObjectContentTypeResolver(Properties) - Constructor for class io.awspring.cloud.s3.PropertiesS3ObjectContentTypeResolver

putBucketAccelerateConfiguration(PutBucketAccelerateConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketAcl(PutBucketAclRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketAnalyticsConfiguration(PutBucketAnalyticsConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketCors(PutBucketCorsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketEncryption(PutBucketEncryptionRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketIntelligentTieringConfiguration(PutBucketIntelligentTieringConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketInventoryConfiguration(PutBucketInventoryConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketLifecycleConfiguration(PutBucketLifecycleConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketLogging(PutBucketLoggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketMetricsConfiguration(PutBucketMetricsConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketNotificationConfiguration(PutBucketNotificationConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketOwnershipControls(PutBucketOwnershipControlsRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketPolicy(PutBucketPolicyRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketReplication(PutBucketReplicationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketRequestPayment(PutBucketRequestPaymentRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketTagging(PutBucketTaggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketVersioning(PutBucketVersioningRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putBucketWebsite(PutBucketWebsiteRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putObject(PutObjectRequest, Path) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putObject(PutObjectRequest, RequestBody) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putObjectAcl(PutObjectAclRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putObjectLegalHold(PutObjectLegalHoldRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putObjectLockConfiguration(PutObjectLockConfigurationRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putObjectRetention(PutObjectRetentionRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putObjectTagging(PutObjectTaggingRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

putPublicAccessBlock(PutPublicAccessBlockRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

Q

query(QueryEnhancedRequest, Class<T>) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Queries a data for a given request.

query(QueryEnhancedRequest, Class<T>) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

queueAttributeNames(Collection<QueueAttributeName>) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

queueAttributeNames(Collection<QueueAttributeName>) - Method in class io.awspring.cloud.sqs.listener.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.listener

Resolves QueueAttributes for the specified queue.

QueueAttributesResolver.Builder - Class in io.awspring.cloud.sqs.listener

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.

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.listener.QueueAttributesResolver.Builder

The queue name.

queueNames() - Element in annotation type 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.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.ContainerOptions.Builder

queueNotFoundStrategy(QueueNotFoundStrategy) - Method in class io.awspring.cloud.sqs.listener.QueueAttributesResolver.Builder

The strategy to be used in case a queue does not exist.

QueueNotFoundStrategy - Enum in io.awspring.cloud.sqs.listener

Configure the strategy to be used when a specified queue is not found at container startup.

R

read(InputStream, Class<T>) - Method in class io.awspring.cloud.s3.Jackson2JsonS3ObjectConverter

read(InputStream, Class<T>) - Method in interface io.awspring.cloud.s3.S3ObjectConverter

Reads S3 object from the input stream into a Java object.

read(String, String, Class<T>) - Method in interface io.awspring.cloud.s3.S3Operations

Reads a Java object from a S3 bucket.

read(String, String, Class<T>) - Method in class io.awspring.cloud.s3.S3Template

reconfigureLoggers(DeferredLogFactory, String...) - Static method in class io.awspring.cloud.autoconfigure.config.BootstrapLoggingHelper

REFRESH - Enum constant in enum io.awspring.cloud.autoconfigure.config.reload.ReloadStrategy

Fire a refresh of beans annotated with @ConfigurationProperties or @RefreshScope.

RegionDiscoveryException(String, S3Exception) - Constructor for exception io.awspring.cloud.s3.crossregion.CrossRegionS3Client.RegionDiscoveryException

RegionProperties - Class in io.awspring.cloud.autoconfigure.core

Properties related to AWS region configuration.

RegionProperties() - Constructor for class io.awspring.cloud.autoconfigure.core.RegionProperties

regionProvider() - Method in class io.awspring.cloud.autoconfigure.core.RegionProviderAutoConfiguration

RegionProviderAutoConfiguration - Class in io.awspring.cloud.autoconfigure.core

EnableAutoConfiguration for AwsRegionProvider.

RegionProviderAutoConfiguration(RegionProperties) - Constructor for class io.awspring.cloud.autoconfigure.core.RegionProviderAutoConfiguration

registerAndPromoteBean(ConfigDataLocationResolverContext, Class<C>, BootstrapRegistry.InstanceSupplier<C>) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

registerBean(ConfigDataLocationResolverContext, Class<C>, C) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

registerBean(ConfigDataLocationResolverContext, Class<C>, BootstrapRegistry.InstanceSupplier<C>) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

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.BackPressureHandler

Release the specified amount of permits.

release(int) - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler

releaseBatch() - Method in interface io.awspring.cloud.sqs.listener.BatchAwareBackPressureHandler

Release a batch of permits.

releaseBatch() - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler

releaseUnusedPermits(int, Collection<S>) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource

reloadProperties() - Method in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

ReloadProperties - Class in io.awspring.cloud.autoconfigure.config.reload

Configuration related to reloading properties.

ReloadProperties() - Constructor for class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

ReloadStrategy - Enum in io.awspring.cloud.autoconfigure.config.reload

Configuration for reload strategies.

request(int) - Method in interface io.awspring.cloud.sqs.listener.BackPressureHandler

Request a number of permits.

request(int) - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler

requestBatch() - Method in interface io.awspring.cloud.sqs.listener.BatchAwareBackPressureHandler

Request a batch of permits.

requestBatch() - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler

requestPayer(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

requestPayer(RequestPayer) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

resolve(Class) - Method in class io.awspring.cloud.dynamodb.DefaultDynamoDbTableNameResolver

resolve(Class<T>) - Method in interface io.awspring.cloud.dynamodb.DynamoDbTableNameResolver

resolve(Class<T>, String) - Method in class io.awspring.cloud.dynamodb.DefaultDynamoDbTableSchemaResolver

resolve(Class<T>, String) - Method in interface io.awspring.cloud.dynamodb.DynamoDbTableSchemaResolver

resolve(String, ResourceLoader) - Method in class io.awspring.cloud.s3.S3ProtocolResolver

resolve(ConfigDataLocationResolverContext, ConfigDataLocation) - Method in class io.awspring.cloud.autoconfigure.config.AbstractAwsConfigDataLocationResolver

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.QueueAttributesMethodArgumentResolver

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

resolveArgument(MethodParameter, ModelAndViewContainer, NativeWebRequest, WebDataBinderFactory) - Method in class io.awspring.cloud.sns.handlers.AbstractNotificationMessageHandlerMethodArgumentResolver

resolveAsInteger(String, String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

resolveAsString(String, String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

resolveContentType(String) - Method in class io.awspring.cloud.s3.PropertiesS3ObjectContentTypeResolver

resolveContentType(String) - Method in interface io.awspring.cloud.s3.S3ObjectContentTypeResolver

Resolves content type from a file name.

resolveExtension(String) - Method in class io.awspring.cloud.s3.PropertiesS3ObjectContentTypeResolver

resolveProfileSpecific(ConfigDataLocationResolverContext, ConfigDataLocation, Profiles) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataLocationResolver

resolveProfileSpecific(ConfigDataLocationResolverContext, ConfigDataLocation, Profiles) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLocationResolver

resolveQueueAttributes() - Method in class io.awspring.cloud.sqs.listener.QueueAttributesResolver

resolveRegion(AwsClientProperties) - Method in class io.awspring.cloud.autoconfigure.core.AwsClientBuilderConfigurer

resolveRegion(AwsClientProperties, AwsRegionProvider) - Static method in class io.awspring.cloud.autoconfigure.core.AwsClientBuilderConfigurer

resolveStringArray(String[], String) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

resolveTopicArn(String) - Method in class io.awspring.cloud.sns.core.CachingTopicArnResolver

resolveTopicArn(String) - Method in class io.awspring.cloud.sns.core.DefaultTopicArnResolver

Resolves topic ARN by topic name.

resolveTopicArn(String) - Method in interface io.awspring.cloud.sns.core.TopicArnResolver

RESTART_CONTEXT - Enum constant in enum io.awspring.cloud.autoconfigure.config.reload.ReloadStrategy

Restarts the Spring ApplicationContext to apply the new configuration.

restoreObject(RestoreObjectRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

run() - Method in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationUpdateStrategy

runBackPressureReleaseCallback() - Method in class io.awspring.cloud.sqs.listener.MessageProcessingContext

S

S3AutoConfiguration - Class in io.awspring.cloud.autoconfigure.s3

EnableAutoConfiguration for S3Client and S3ProtocolResolver.

S3AutoConfiguration(S3Properties) - Constructor for class io.awspring.cloud.autoconfigure.s3.S3AutoConfiguration

S3Exception - Exception in io.awspring.cloud.s3

Exception thrown when S3 operation fails.

S3Exception(String, Throwable) - Constructor for exception io.awspring.cloud.s3.S3Exception

S3ObjectContentTypeResolver - Interface in io.awspring.cloud.s3

Resolves content type of S3 objects.

S3ObjectConverter - Interface in io.awspring.cloud.s3

Converter used to serialize Java objects into S3 objects.

S3Operations - Interface in io.awspring.cloud.s3

S3OutputStream - Class in io.awspring.cloud.s3

Represents OutputStream that writes data to S3.

S3OutputStream() - Constructor for class io.awspring.cloud.s3.S3OutputStream

S3OutputStreamProvider - Interface in io.awspring.cloud.s3

Creates an OutputStream that writes data to S3.

S3Properties - Class in io.awspring.cloud.autoconfigure.s3.properties

Properties related to AWS S3.

S3Properties() - Constructor for class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

S3ProtocolResolver - Class in io.awspring.cloud.s3

Resolves S3Resource for resources paths starting from s3://.

S3ProtocolResolver() - Constructor for class io.awspring.cloud.s3.S3ProtocolResolver

S3Resource - Class in io.awspring.cloud.s3

Resource implementation for S3 objects.

S3Resource(Location, S3Client, S3OutputStreamProvider) - Constructor for class io.awspring.cloud.s3.S3Resource

S3Resource(String, String, S3Client, S3OutputStreamProvider) - Constructor for class io.awspring.cloud.s3.S3Resource

S3Resource(String, S3Client, S3OutputStreamProvider) - Constructor for class io.awspring.cloud.s3.S3Resource

S3Template - Class in io.awspring.cloud.s3

Higher level abstraction over S3Client providing methods for the most common use cases.

S3Template(S3Client, S3OutputStreamProvider, S3ObjectConverter) - Constructor for class io.awspring.cloud.s3.S3Template

S3TransferManagerAutoConfiguration - Class in io.awspring.cloud.autoconfigure.s3

EnableAutoConfiguration for S3TransferManager

S3TransferManagerAutoConfiguration(S3Properties, AwsProperties, AwsCredentialsProvider, AwsClientBuilderConfigurer) - Constructor for class io.awspring.cloud.autoconfigure.s3.S3TransferManagerAutoConfiguration

S3TransferManagerProperties - Class in io.awspring.cloud.autoconfigure.s3.properties

Properties related to AWS S3 S3TransferManager.

S3TransferManagerProperties() - Constructor for class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

S3TransferManagerProperties.S3UploadDirectoryProperties - Class in io.awspring.cloud.autoconfigure.s3.properties

S3UploadDirectoryProperties() - Constructor for class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties.S3UploadDirectoryProperties

save(T) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Saves Entity to DynamoDB table.

save(T) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

scan(ScanEnhancedRequest, Class<T>) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Scans Table using given request.

scan(ScanEnhancedRequest, Class<T>) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

scanAll(Class<T>) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Scans whole DynamoDB table.

scanAll(Class<T>) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

SecretsManagerConfigDataLoader - Class in io.awspring.cloud.autoconfigure.config.secretsmanager

Loads config data from AWS Secret Manager.

SecretsManagerConfigDataLoader(DeferredLogFactory) - Constructor for class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLoader

SecretsManagerConfigDataLocationResolver - Class in io.awspring.cloud.autoconfigure.config.secretsmanager

Resolves config data locations in AWS Secrets Manager.

SecretsManagerConfigDataLocationResolver(DeferredLogFactory) - Constructor for class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataLocationResolver

SecretsManagerConfigDataResource - Class in io.awspring.cloud.autoconfigure.config.secretsmanager

Config data resource for AWS Secret Manager integration.

SecretsManagerConfigDataResource(String, boolean, SecretsManagerPropertySources) - Constructor for class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataResource

secretsManagerConfigurationUpdateStrategy(SecretsManagerProperties, Optional<RestartEndpoint>, ContextRefresher) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerReloadAutoConfiguration

SecretsManagerKeysMissingException - Exception in io.awspring.cloud.autoconfigure.config.secretsmanager

Thrown when configuration provided to ConfigDataLoader is missing Secrets Manager keys, for example `spring.config.import=aws-secretsmanager:`.

SecretsManagerKeysMissingException(String) - Constructor for exception io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerKeysMissingException

SecretsManagerMissingKeysFailureAnalyzer - Class in io.awspring.cloud.autoconfigure.config.secretsmanager

An AbstractFailureAnalyzer that performs analysis of a Secrets Manager configuration failure caused by not providing a Secrets Manager key to `spring.config.import` property.

SecretsManagerMissingKeysFailureAnalyzer() - Constructor for class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerMissingKeysFailureAnalyzer

secretsManagerPollingAwsPropertySourceChangeDetector(SecretsManagerProperties, ConfigurationUpdateStrategy, TaskSchedulerWrapper<TaskScheduler>, ConfigurableEnvironment) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerReloadAutoConfiguration

SecretsManagerProperties - Class in io.awspring.cloud.autoconfigure.config.secretsmanager

Configuration properties for the AWS Secrets Manager integration.

SecretsManagerProperties() - Constructor for class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerProperties

SecretsManagerPropertySource - Class in io.awspring.cloud.secretsmanager

Retrieves secret value under the given context / path from the AWS Secrets Manager using the provided Secrets Manager client.

SecretsManagerPropertySource(String, SecretsManagerClient) - Constructor for class io.awspring.cloud.secretsmanager.SecretsManagerPropertySource

SecretsManagerPropertySources - Class in io.awspring.cloud.autoconfigure.config.secretsmanager

Provides prefix config import support.

SecretsManagerPropertySources() - Constructor for class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerPropertySources

SecretsManagerReloadAutoConfiguration - Class in io.awspring.cloud.autoconfigure.config.secretsmanager

Auto-Configuration for reloading properties from Secrets Manager.

SecretsManagerReloadAutoConfiguration() - Constructor for class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerReloadAutoConfiguration

secretsManagerTaskScheduler() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerReloadAutoConfiguration

SemaphoreBackPressureHandler - Class in io.awspring.cloud.sqs.listener

BackPressureHandler implementation that uses a Semaphore for handling backpressure.

SemaphoreBackPressureHandler.Builder - Class in io.awspring.cloud.sqs.listener

send(MimeMessage) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

send(MimeMessage...) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

send(String, String) - Method in interface io.awspring.cloud.sns.sms.SnsSmsOperations

Sends SMS directly to a phone number without a need for a phone number to be subscribed to an SNS topic.

send(String, String, SmsMessageAttributes) - Method in interface io.awspring.cloud.sns.sms.SnsSmsOperations

Sends SMS directly to a phone number without a need for a phone number to be subscribed to an SNS topic.

send(String, String, SmsMessageAttributes) - Method in class io.awspring.cloud.sns.sms.SnsSmsTemplate

send(String, Message<?>) - Method in class io.awspring.cloud.sns.core.SnsTemplate

send(MimeMessagePreparator) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

send(MimeMessagePreparator...) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

send(SimpleMailMessage) - Method in class io.awspring.cloud.ses.SimpleEmailServiceMailSender

send(SimpleMailMessage...) - Method in class io.awspring.cloud.ses.SimpleEmailServiceMailSender

sendAnEmail(MailSender, SesClient) - Static method in class io.awspring.cloud.samples.ses.MailSendingApplication

senderID(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes.Builder

sendInternal(Message<?>, long) - Method in class io.awspring.cloud.sns.core.TopicMessageChannel

sendNotification(Object, String) - Method in class io.awspring.cloud.sns.core.SnsTemplate

Convenience method that sends a notification with the given message and subject to the destination.

sendNotification(String, SnsNotification<?>) - Method in interface io.awspring.cloud.sns.core.SnsOperations

Sends a notification to a topic.

sendNotification(String, SnsNotification<?>) - Method in class io.awspring.cloud.sns.core.SnsTemplate

sendNotification(String, Object, String) - Method in class io.awspring.cloud.sns.core.SnsTemplate

Convenience method that sends a notification with the given message and subject to the destination.

sendToExecutor(Collection<Message<T>>) - Method in class io.awspring.cloud.sqs.listener.acknowledgement.AbstractOrderingAcknowledgementProcessor

sendToTopicArn(String, String) - Method in interface io.awspring.cloud.sns.sms.SnsSmsOperations

Sends SMS to a topic to which phone numbers are subscribed.

sendToTopicArn(String, String, SmsMessageAttributes) - Method in interface io.awspring.cloud.sns.sms.SnsSmsOperations

Sends SMS to a topic to which phone numbers are subscribed.

sendToTopicArn(String, String, SmsMessageAttributes) - Method in class io.awspring.cloud.sns.sms.SnsSmsTemplate

serverSideEncryption(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

serverSideEncryption(ServerSideEncryption) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

serviceName() - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

SesAutoConfiguration - Class in io.awspring.cloud.autoconfigure.ses

EnableAutoConfiguration for SimpleEmailServiceMailSender and SimpleEmailServiceJavaMailSender.

SesAutoConfiguration() - Constructor for class io.awspring.cloud.autoconfigure.ses.SesAutoConfiguration

sesClient(SesProperties, AwsClientBuilderConfigurer, ObjectProvider<AwsClientCustomizer<SesClientBuilder>>) - Method in class io.awspring.cloud.autoconfigure.ses.SesAutoConfiguration

SesProperties - Class in io.awspring.cloud.autoconfigure.ses

Properties related to AWS Simple Email Service.

SesProperties() - Constructor for class io.awspring.cloud.autoconfigure.ses.SesProperties

setAccelerateModeEnabled(Boolean) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

setAccessKey(String) - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

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

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

setChecksumValidationEnabled(Boolean) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

setChunkedEncodingEnabled(Boolean) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

setClusterUpdateIntervalMillis(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setComponentFactories(Collection<ContainerComponentFactory<T>>) - Method in class io.awspring.cloud.sqs.listener.AbstractMessageListenerContainer

setConnectionTtlMillis(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setConnectTimeoutMillis(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setContainerComponentFactories(Collection<ContainerComponentFactory<T>>) - 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.

setDax(DaxProperties) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DynamoDbProperties

setDefaultDestinationName(String) - Method in class io.awspring.cloud.sns.core.SnsTemplate

setDefaultEncoding(String) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

Set the default encoding to use for MimeMessages created by this instance.

setDefaultFileTypeMap(FileTypeMap) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

Set the default Java Activation FileTypeMap to use for MimeMessages created by this instance.

setDefaultListenerContainerFactoryBeanName(String) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar

Set the bean name for the default MessageListenerContainerFactory.

setDefaultsMode(DefaultsMode) - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

setDepartmentId(UUID) - Method in class io.awspring.cloud.samples.dynamodb.Department

setDualstackEnabled(Boolean) - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

setEmbeddedValueResolver(StringValueResolver) - Method in class io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor

setEmployeeNumber(Long) - Method in class io.awspring.cloud.samples.dynamodb.Department

setEndpoint(URI) - Method in class io.awspring.cloud.autoconfigure.AwsClientProperties

setEndpoint(URI) - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

setEndpointRefreshTimeoutMillis(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setEntityId(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

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.

setFipsEnabled(Boolean) - Method in class io.awspring.cloud.autoconfigure.core.AwsProperties

setFollowSymbolicLinks(Boolean) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties.S3UploadDirectoryProperties

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 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.SemaphoreBackPressureHandler

setId(String) - Method in class io.awspring.cloud.sqs.listener.source.AbstractPollingMessageSource

setIdleTimeoutMillis(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setInstanceProfile(boolean) - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

setInstanceProfile(boolean) - Method in class io.awspring.cloud.autoconfigure.core.RegionProperties

setJavaMailProperties(Properties) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

Set JavaMail properties for the Session.

setListener(SqsProperties.Listener) - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties

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

setMaxConcurrency(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setMaxConcurrency(Integer) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

setMaxDepth(Integer) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties.S3UploadDirectoryProperties

setMaxInflightMessagesPerQueue(Integer) - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties.Listener

setMaxMessagesPerPoll(Integer) - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties.Listener

setMaxPendingConnectionAcquires(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setMaxPrice(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

setMaxWaitForRestart(Duration) - Method in class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

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.

setMinimumPartSizeInBytes(Long) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

setName(String) - Method in class io.awspring.cloud.autoconfigure.core.Profile

setNamespace(String) - Method in class io.awspring.cloud.autoconfigure.metrics.CloudWatchRegistryProperties

setObjectMapper(ObjectMapper) - Method in class io.awspring.cloud.sqs.config.EndpointRegistrar

Set the object mapper to be used to deserialize payloads fot SqsListener endpoints.

setObjectMetadata(ObjectMetadata) - Method in class io.awspring.cloud.s3.S3Resource

setOpeningDate(LocalDate) - Method in class io.awspring.cloud.samples.dynamodb.Department

setOriginationNumber(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

setParallelLifecycle(boolean) - Method in class io.awspring.cloud.sqs.LifecycleHandler

Set whether lifecycle management should be handled in parallel or sequentially.

setPath(String) - Method in class io.awspring.cloud.autoconfigure.core.Profile

setPathStyleAccessEnabled(Boolean) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

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 by the AbstractMessagingMessageConverter.defaultHeaderTypeMapping(Message).

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.

setPeriod(Duration) - Method in class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

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.

setPollTimeout(Duration) - Method in class io.awspring.cloud.autoconfigure.sqs.SqsProperties.Listener

setProfile(Profile) - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

setProfile(Profile) - Method in class io.awspring.cloud.autoconfigure.core.RegionProperties

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

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.

setReadRetries(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setRecursive(Boolean) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties.S3UploadDirectoryProperties

setRegion(String) - Method in class io.awspring.cloud.autoconfigure.AwsClientProperties

setReload(ReloadProperties) - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreProperties

setReload(ReloadProperties) - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerProperties

setRequestTimeoutMillis(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setResourceLoader(ResourceLoader) - Method in class io.awspring.cloud.s3.S3ProtocolResolver

setSecretKey(String) - Method in class io.awspring.cloud.autoconfigure.core.CredentialsProperties

setSenderID(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

setSession(Session) - Method in class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

Set the JavaMail Session, possibly pulled from JNDI.

setSkipHostNameVerification(Boolean) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setSmsType(SmsType) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

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.

setStatic(String) - Method in class io.awspring.cloud.autoconfigure.core.RegionProperties

setStrategy(ReloadStrategy) - Method in class io.awspring.cloud.autoconfigure.config.reload.ReloadProperties

setTargetThroughputInGbps(Double) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

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.

setTemplateId(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes

setTransferManager(S3TransferManagerProperties) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

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.

setUploadDirectory(S3TransferManagerProperties.S3UploadDirectoryProperties) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3TransferManagerProperties

setUrl(String) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

setUseArnRegionEnabled(Boolean) - Method in class io.awspring.cloud.autoconfigure.s3.properties.S3Properties

setUserId(UUID) - Method in class io.awspring.cloud.samples.dynamodb.Department

setWriteRetries(Integer) - Method in class io.awspring.cloud.autoconfigure.dynamodb.DaxProperties

shutdownTimeout(Duration) - Method in class io.awspring.cloud.sqs.listener.ContainerOptions.Builder

SimpleEmailServiceJavaMailSender - Class in io.awspring.cloud.ses

JavaMailSender implementation that allows to send MimeMessage using the Simple E-Mail Service.

SimpleEmailServiceJavaMailSender(SesClient) - Constructor for class io.awspring.cloud.ses.SimpleEmailServiceJavaMailSender

SimpleEmailServiceMailSender - Class in io.awspring.cloud.ses

Simple MailSender implementation to send E-Mails with the Amazon Simple Email Service.

SimpleEmailServiceMailSender(SesClient) - Constructor for class io.awspring.cloud.ses.SimpleEmailServiceMailSender

simpleMailSender(SesClient) - Method in class io.awspring.cloud.autoconfigure.ses.SesAutoConfiguration

SINGLE_MESSAGE - Enum constant in enum io.awspring.cloud.sqs.listener.ListenerMode

Configure the container to receive one message at a time in its components.

SmsMessageAttributes - Class in io.awspring.cloud.sns.sms

Helper class that is transformed to MessageAttributeValue when sending SMS via SNS.

SmsMessageAttributes() - Constructor for class io.awspring.cloud.sns.sms.SmsMessageAttributes

SmsMessageAttributes.Builder - Class in io.awspring.cloud.sns.sms

smsType(SmsType) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes.Builder

SmsType - Enum in io.awspring.cloud.sns.sms

The type of message that you're sending.

SnsAutoConfiguration - Class in io.awspring.cloud.autoconfigure.sns

Auto-configuration for SNS integration.

SnsAutoConfiguration() - Constructor for class io.awspring.cloud.autoconfigure.sns.SnsAutoConfiguration

snsClient(SnsProperties, AwsClientBuilderConfigurer, ObjectProvider<AwsClientCustomizer<SnsClientBuilder>>) - Method in class io.awspring.cloud.autoconfigure.sns.SnsAutoConfiguration

SnsHeaders - Class in io.awspring.cloud.sns.core

SNS specific headers that can be applied to Spring Messaging Message.

SnsNotification<T> - Class in io.awspring.cloud.sns.core

SNS notification object.

SnsNotification(T, Map<String, Object>) - Constructor for class io.awspring.cloud.sns.core.SnsNotification

SnsNotification.Builder<T> - Class in io.awspring.cloud.sns.core

SnsOperations - Interface in io.awspring.cloud.sns.core

High level SNS operations.

SnsProperties - Class in io.awspring.cloud.autoconfigure.sns

Properties related to AWS SNS.

SnsProperties() - Constructor for class io.awspring.cloud.autoconfigure.sns.SnsProperties

SnsSmsOperations - Interface in io.awspring.cloud.sns.sms

High level SNS operations for sending SMS.

snsSmsTemplate(SnsClient) - Method in class io.awspring.cloud.autoconfigure.sns.SnsAutoConfiguration

SnsSmsTemplate - Class in io.awspring.cloud.sns.sms

Helper class abstraction over SnsClient tailored for sending SMS messages to SNS topics and phone numbers.

SnsSmsTemplate(SnsClient) - Constructor for class io.awspring.cloud.sns.sms.SnsSmsTemplate

snsTemplate(SnsClient, Optional<ObjectMapper>, Optional<TopicArnResolver>) - Method in class io.awspring.cloud.autoconfigure.sns.SnsAutoConfiguration

SnsTemplate - Class in io.awspring.cloud.sns.core

Helper class that simplifies synchronous sending of notifications to SNS.

SnsTemplate(SnsClient) - Constructor for class io.awspring.cloud.sns.core.SnsTemplate

SnsTemplate(SnsClient, TopicArnResolver, MessageConverter) - Constructor for class io.awspring.cloud.sns.core.SnsTemplate

SnsTemplate(SnsClient, MessageConverter) - Constructor for class io.awspring.cloud.sns.core.SnsTemplate

SpringCloudAwsParameterStoreSample - Class in io.awspring.cloud.samples.parameterstore

SpringCloudAwsParameterStoreSample() - Constructor for class io.awspring.cloud.samples.parameterstore.SpringCloudAwsParameterStoreSample

SpringCloudAwsS3Sample - Class in io.awspring.cloud.samples.s3

SpringCloudAwsS3Sample() - Constructor for class io.awspring.cloud.samples.s3.SpringCloudAwsS3Sample

SpringCloudClientConfiguration - Class in io.awspring.cloud.core

Utility class for creating ClientOverrideConfiguration containing "Spring Cloud AWS" user agent.

SpringCloudClientConfiguration() - Constructor for class io.awspring.cloud.core.SpringCloudClientConfiguration

SpringCloudClientConfiguration(String) - Constructor for class io.awspring.cloud.core.SpringCloudClientConfiguration

SpringDynamoDbSample - Class in io.awspring.cloud.samples.dynamodb

SpringDynamoDbSample() - Constructor for class io.awspring.cloud.samples.dynamodb.SpringDynamoDbSample

SpringSNSSample - Class in io.awspring.cloud.sns.sample

SpringSNSSample() - Constructor for class io.awspring.cloud.sns.sample.SpringSNSSample

SQS_ACKNOWLEDGMENT_CALLBACK_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders

Header for a AcknowledgementCallback for this message.

SQS_APPROXIMATE_FIRST_RECEIVE_TIMESTAMP - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

ApproximateFirstReceiveTimestamp header in a SQS message.

SQS_APPROXIMATE_RECEIVE_COUNT - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

ApproximateReceiveCount header in a SQS message.

SQS_AWS_TRACE_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

SenderId header in a SQS message.

SQS_DEDUPLICATION_ID_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

Deduplication header in a SQS message.

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_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_MA_HEADER_PREFIX - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders

MessageAttributes prefix to be used by all headers mapped from SQS Message Attributes.

SQS_MESSAGE_GROUP_ID_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

Group id header in a SQS message.

SQS_MSA_HEADER_PREFIX - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

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_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.MessageSystemAttribute

SenderId header in a SQS message.

SQS_SENT_TIMESTAMP - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

SentTimestamp header in a SQS message.

SQS_SEQUENCE_NUMBER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders.MessageSystemAttribute

SenderId header in a SQS message.

SQS_SOURCE_DATA_HEADER - Static variable in class io.awspring.cloud.sqs.listener.SqsHeaders

Header for the original SQS Message.

SQS_VISIBILITY_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.listener.acknowledgement

RuntimeException that wraps an error thrown during acknowledgement execution.

SqsAcknowledgementException(String, Collection<Message<T>>, String, Throwable) - Constructor for exception io.awspring.cloud.sqs.listener.acknowledgement.SqsAcknowledgementException

Contruct 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(AwsClientBuilderConfigurer, ObjectProvider<AwsClientCustomizer<SqsAsyncClientBuilder>>) - Method in class io.awspring.cloud.autoconfigure.sqs.SqsAutoConfiguration

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.QueueAttributesResolver.Builder

The SqsAsyncClient to be used to resolve the queue attributes.

sqsAsyncClient(SqsAsyncClient) - Method in class io.awspring.cloud.sqs.listener.SqsMessageListenerContainer.Builder

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.

SqsAutoConfiguration - Class in io.awspring.cloud.autoconfigure.sqs

Auto-configuration for SQS integration.

SqsAutoConfiguration(SqsProperties) - Constructor for class io.awspring.cloud.autoconfigure.sqs.SqsAutoConfiguration

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

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.

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.MessageSystemAttribute - Class in io.awspring.cloud.sqs.listener

SqsListener - Annotation Type in io.awspring.cloud.sqs.annotation

Methods with this annotation will be wrapped by a MessageListener or AsyncMessageListener and set to a MessageListenerContainer.

SqsListenerAnnotationBeanPostProcessor - 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.

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.

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

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, ContainerOptions) - 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

SqsProperties - Class in io.awspring.cloud.autoconfigure.sqs

Properties related to AWS SQS.

SqsProperties() - Constructor for class io.awspring.cloud.autoconfigure.sqs.SqsProperties

SqsProperties.Listener - Class in io.awspring.cloud.autoconfigure.sqs

SqsTest - Annotation Type in io.awspring.cloud.test.sqs

Annotation for a SQS test that focuses only on SQS-based components.

SqsTestContextBootstrapper - Class in io.awspring.cloud.test.sqs

TestContextBootstrapper for @SqsTest support.

SqsTestContextBootstrapper() - Constructor for class io.awspring.cloud.test.sqs.SqsTestContextBootstrapper

SqsTypeExcludeFilter - Class in io.awspring.cloud.test.sqs

TypeExcludeFilter for @SqsTest.

sseCustomerAlgorithm(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

sseCustomerKey(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

sseCustomerKeyMD5(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

ssekmsEncryptionContext(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

ssekmsKeyId(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

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.

StaticRegionProvider - Class in io.awspring.cloud.core.region

Static AwsRegionProvider implementation that can used to statically configure a region.

StaticRegionProvider(String) - Constructor for class io.awspring.cloud.core.region.StaticRegionProvider

Constructs and configures the static region for this RegionProvider implementation.

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.

storageClass(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

storageClass(StorageClass) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

store(String, String, Object) - Method in interface io.awspring.cloud.s3.S3Operations

Stores a Java object in a S3 bucket.

store(String, String, Object) - Method in class io.awspring.cloud.s3.S3Template

strategy - Variable in class io.awspring.cloud.autoconfigure.config.reload.ConfigurationChangeDetector

STRING - Static variable in class io.awspring.cloud.sns.core.MessageAttributeDataTypes

String message attribute data type.

STRING_ARRAY - Static variable in class io.awspring.cloud.sns.core.MessageAttributeDataTypes

String.Array message attribute data type.

subject(String) - Method in class io.awspring.cloud.sns.core.SnsNotification.Builder

supports(Collection<String>, ContainerOptions) - Method in interface io.awspring.cloud.sqs.listener.ContainerComponentFactory

Whether this factory supports the given queues based on the queue names.

supports(Collection<String>, ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.FifoSqsComponentFactory

supports(Collection<String>, ContainerOptions) - Method in class io.awspring.cloud.sqs.listener.StandardSqsComponentFactory

supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sns.handlers.NotificationMessageHandlerMethodArgumentResolver

supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sns.handlers.NotificationStatusHandlerMethodArgumentResolver

supportsParameter(MethodParameter) - Method in class io.awspring.cloud.sns.handlers.NotificationSubjectHandlerMethodArgumentResolver

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.QueueAttributesMethodArgumentResolver

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

tagging(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

TaskExecutorAware - Interface in io.awspring.cloud.sqs.listener

Enables a class to receive a container managed TaskExecutor.

taskScheduler() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreReloadAutoConfiguration

templateId(String) - Method in class io.awspring.cloud.sns.sms.SmsMessageAttributes.Builder

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

throughputConfiguration(BackPressureMode) - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler.Builder

toBuilder() - Method in class io.awspring.cloud.sqs.listener.ContainerOptions

toHeaders(Message) - Method in class io.awspring.cloud.sqs.support.converter.SqsHeaderMapper

toMessagingMessage(S) - Method in interface io.awspring.cloud.sqs.support.converter.ContextAwareMessagingMessageConverter

toMessagingMessage(S) - Method in interface io.awspring.cloud.sqs.support.converter.MessagingMessageConverter

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

TopicArnResolver - Interface in io.awspring.cloud.sns.core

Resolves topic ARN by name.

TopicMessageChannel - Class in io.awspring.cloud.sns.core

Implementation of AbstractMessageChannel which is used for converting and sending messages via SnsClient to SNS.

TopicMessageChannel(SnsClient, Arn) - Constructor for class io.awspring.cloud.sns.core.TopicMessageChannel

toString() - Method in class io.awspring.cloud.autoconfigure.config.parameterstore.ParameterStoreConfigDataResource

toString() - Method in class io.awspring.cloud.autoconfigure.config.secretsmanager.SecretsManagerConfigDataResource

totalPermits(int) - Method in class io.awspring.cloud.sqs.listener.SemaphoreBackPressureHandler.Builder

TRANSACTIONAL - Enum constant in enum io.awspring.cloud.sns.sms.SmsType

Critical messages that support customer transactions.

TransferManagerS3OutputStreamProvider - Class in io.awspring.cloud.s3

Creates TransferManagerS3OutputStream.

TransferManagerS3OutputStreamProvider(S3TransferManager, S3ObjectContentTypeResolver) - Constructor for class io.awspring.cloud.s3.TransferManagerS3OutputStreamProvider

U

unwrapMessage(Throwable) - Static method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException

Look for a potentially nested ListenerExecutionFailedException and if found return the wrapped Message instance.

unwrapMessages(Throwable) - Static method in exception io.awspring.cloud.sqs.listener.ListenerExecutionFailedException

Look for a potentially nested ListenerExecutionFailedException and if found return the wrapped Message instances.

update(T) - Method in interface io.awspring.cloud.dynamodb.DynamoDbOperations

Updated Entity to DynamoDB table.

update(T) - Method in class io.awspring.cloud.dynamodb.DynamoDbTemplate

upload(String, String, InputStream) - Method in interface io.awspring.cloud.s3.S3Operations

Uploads data from an input stream to a S3 bucket.

upload(String, String, InputStream, ObjectMetadata) - Method in interface io.awspring.cloud.s3.S3Operations

Uploads data from an input stream to a S3 bucket.

upload(String, String, InputStream, ObjectMetadata) - Method in class io.awspring.cloud.s3.S3Template

UploadFailedException - Exception in io.awspring.cloud.s3

Thrown when uploading to S3 fails.

UploadFailedException(String, Exception) - Constructor for exception io.awspring.cloud.s3.UploadFailedException

uploadPart(UploadPartRequest, Path) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

uploadPart(UploadPartRequest, RequestBody) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

uploadPartCopy(UploadPartCopyRequest) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

useDefaultFilters() - Element in annotation type io.awspring.cloud.test.sqs.SqsTest

Determines if default filtering should be used with @SpringBootApplication.

V

validate(Message<?>, MethodParameter, Object) - Method in class io.awspring.cloud.sqs.support.resolver.BatchPayloadMethodArgumentResolver

Validate the payload if applicable.

value() - Element in annotation type io.awspring.cloud.sqs.annotation.SqsListener

Array of queue names or urls.

value() - Element in annotation type io.awspring.cloud.test.sqs.SqsTest

Specifies the listeners to test.

valueOf(String) - Static method in enum io.awspring.cloud.autoconfigure.config.reload.ReloadStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.awspring.cloud.sns.sms.SmsType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.awspring.cloud.sqs.listener.BackPressureMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.awspring.cloud.sqs.listener.ListenerMode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum io.awspring.cloud.sqs.listener.QueueNotFoundStrategy

Returns the enum constant of this type with the specified name.

values() - Static method in enum io.awspring.cloud.autoconfigure.config.reload.ReloadStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.awspring.cloud.sns.sms.SmsType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.awspring.cloud.sqs.listener.acknowledgement.AcknowledgementOrdering

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.awspring.cloud.sqs.listener.acknowledgement.handler.AcknowledgementMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.awspring.cloud.sqs.listener.BackPressureMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.awspring.cloud.sqs.listener.ListenerMode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum io.awspring.cloud.sqs.listener.QueueNotFoundStrategy

Returns an array containing the constants of this enum type, 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

W

websiteRedirectLocation(String) - Method in class io.awspring.cloud.s3.ObjectMetadata.Builder

withDepartmentId(UUID) - Method in class io.awspring.cloud.samples.dynamodb.Department.Builder

withEmployeeNumber(Long) - Method in class io.awspring.cloud.samples.dynamodb.Department.Builder

withOpeningDate(LocalDate) - Method in class io.awspring.cloud.samples.dynamodb.Department.Builder

withUserId(UUID) - Method in class io.awspring.cloud.samples.dynamodb.Department.Builder

write(int) - Method in class io.awspring.cloud.s3.InMemoryBufferingS3OutputStream

write(T) - Method in class io.awspring.cloud.s3.Jackson2JsonS3ObjectConverter

write(T) - Method in interface io.awspring.cloud.s3.S3ObjectConverter

Converts object into a RequestBody.

writeGetObjectResponse(WriteGetObjectResponseRequest, Path) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

writeGetObjectResponse(WriteGetObjectResponseRequest, RequestBody) - Method in class io.awspring.cloud.s3.crossregion.CrossRegionS3Client

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