Package io.awspring.cloud.autoconfigure.sqs

Class SqsAutoConfiguration

java.lang.Object

io.awspring.cloud.autoconfigure.sqs.SqsAutoConfiguration

@AutoConfiguration
@ConditionalOnClass({software.amazon.awssdk.services.sqs.SqsAsyncClient.class,io.awspring.cloud.sqs.config.SqsBootstrapConfiguration.class})
@EnableConfigurationProperties(SqsProperties.class)
@Import(io.awspring.cloud.sqs.config.SqsBootstrapConfiguration.class)
@AutoConfigureAfter({CredentialsProviderAutoConfiguration.class,RegionProviderAutoConfiguration.class})
@ConditionalOnProperty(name="spring.cloud.aws.sqs.enabled",
                       havingValue="true",
                       matchIfMissing=true)
public class SqsAutoConfiguration
extends Object

Auto-configuration for SQS integration.

Since:

3.0

Author:

Tomaz Fernandes, Maciej Walkowiak, Wei Jiang, Dongha Kim

Constructor Summary

Constructors

Constructor	Description
SqsAutoConfiguration(SqsProperties sqsProperties)

Method Summary

Modifier and Type	Method	Description
io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory<Object>	defaultSqsListenerContainerFactory(ObjectProvider<software.amazon.awssdk.services.sqs.SqsAsyncClient> sqsAsyncClient, ObjectProvider<io.awspring.cloud.sqs.listener.errorhandler.AsyncErrorHandler<Object>> asyncErrorHandler, ObjectProvider<io.awspring.cloud.sqs.listener.errorhandler.ErrorHandler<Object>> errorHandler, ObjectProvider<io.awspring.cloud.sqs.listener.interceptor.AsyncMessageInterceptor<Object>> asyncInterceptors, ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistry, ObjectProvider<io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Convention> observationConventionProvider, ObjectProvider<io.awspring.cloud.sqs.listener.interceptor.MessageInterceptor<Object>> interceptors, ObjectProvider<io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration> messageConverterFactory, io.awspring.cloud.sqs.support.converter.MessagingMessageConverter<?> messagingMessageConverter)
io.awspring.cloud.sqs.config.SqsListenerConfigurer	jacksonMessageConverterMigrationCustomizer(ObjectProvider<io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration> factoryProvider)
software.amazon.awssdk.services.sqs.SqsAsyncClient	sqsAsyncClient(AwsClientBuilderConfigurer awsClientBuilderConfigurer, ObjectProvider<AwsConnectionDetails> connectionDetails, ObjectProvider<SqsAsyncClientCustomizer> sqsAsyncClientCustomizers, ObjectProvider<AwsAsyncClientCustomizer> awsAsyncClientCustomizers)
io.awspring.cloud.sqs.operations.SqsTemplate	sqsTemplate(software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient, ObjectProvider<io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration> messageConverterFactory, ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistryProvider, ObjectProvider<io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Convention> observationConventionProvider, io.awspring.cloud.sqs.support.converter.MessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message> messageConverter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SqsAutoConfiguration

public SqsAutoConfiguration(SqsProperties sqsProperties)

Method Details

sqsAsyncClient

@ConditionalOnMissingBean
@Bean
public software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient(AwsClientBuilderConfigurer awsClientBuilderConfigurer,
 ObjectProvider<AwsConnectionDetails> connectionDetails,
 ObjectProvider<SqsAsyncClientCustomizer> sqsAsyncClientCustomizers,
 ObjectProvider<AwsAsyncClientCustomizer> awsAsyncClientCustomizers)

sqsTemplate

@ConditionalOnMissingBean
@Bean
public io.awspring.cloud.sqs.operations.SqsTemplate sqsTemplate(software.amazon.awssdk.services.sqs.SqsAsyncClient sqsAsyncClient,
 ObjectProvider<io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration> messageConverterFactory,
 ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistryProvider,
 ObjectProvider<io.awspring.cloud.sqs.support.observation.SqsTemplateObservation.Convention> observationConventionProvider,
 io.awspring.cloud.sqs.support.converter.MessagingMessageConverter<software.amazon.awssdk.services.sqs.model.Message> messageConverter)

defaultSqsListenerContainerFactory

@ConditionalOnMissingBean
@Bean
public io.awspring.cloud.sqs.config.SqsMessageListenerContainerFactory<Object> defaultSqsListenerContainerFactory(ObjectProvider<software.amazon.awssdk.services.sqs.SqsAsyncClient> sqsAsyncClient,
 ObjectProvider<io.awspring.cloud.sqs.listener.errorhandler.AsyncErrorHandler<Object>> asyncErrorHandler,
 ObjectProvider<io.awspring.cloud.sqs.listener.errorhandler.ErrorHandler<Object>> errorHandler,
 ObjectProvider<io.awspring.cloud.sqs.listener.interceptor.AsyncMessageInterceptor<Object>> asyncInterceptors,
 ObjectProvider<io.micrometer.observation.ObservationRegistry> observationRegistry,
 ObjectProvider<io.awspring.cloud.sqs.support.observation.SqsListenerObservation.Convention> observationConventionProvider,
 ObjectProvider<io.awspring.cloud.sqs.listener.interceptor.MessageInterceptor<Object>> interceptors,
 ObjectProvider<io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration> messageConverterFactory,
 io.awspring.cloud.sqs.support.converter.MessagingMessageConverter<?> messagingMessageConverter)

jacksonMessageConverterMigrationCustomizer

@Bean
public io.awspring.cloud.sqs.config.SqsListenerConfigurer jacksonMessageConverterMigrationCustomizer(ObjectProvider<io.awspring.cloud.sqs.support.converter.legacy.JacksonMessageConverterMigration> factoryProvider)