[custom config aws sdk v2 sqs for java] sqs

build.gradle.kts

dependencyManagement {
    imports {
        mavenBom("software.amazon.awssdk:bom:2.5.5")
    }
}

dependencies {
  	implementation("software.amazon.awssdk:sqs")
}

ReactiveSQSConfig.java

import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.context.annotation.Profile;
import software.amazon.awssdk.auth.credentials.AwsCredentials;
import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.sqs.SqsAsyncClient;

import java.net.URI;

@Slf4j
@Configuration
public class ReactiveSQSConfig {

	@Value("${cloud.aws.sqs.endpoint:#{null}}")
	String endpoint;

	@Value("${cloud.aws.sqs.region}")
	String region;

	@Value("${cloud.aws.credentials.access-key}")
	String accessKey;

	@Value("${cloud.aws.credentials.secret-key}")
	String secretKey;

	@Bean
	@Primary
	@Profile("(local || default || secrets) && !test")
	public SqsAsyncClient amazonSQSAsyncClientLocal() {
		return SqsAsyncClient.builder()
			.endpointOverride(URI.create(endpoint))
			.region(Region.EU_WEST_1)
			.credentialsProvider(StaticCredentialsProvider.create(new AwsCredentials() {
				@Override
				public String accessKeyId() {
					return accessKey;
				}

				@Override
				public String secretAccessKey() {
					return secretKey;
				}
			}))
			.build();
	}

	@Bean
	@Profile("!local && !default && !test && !secrets")
	public SqsAsyncClient amazonSQSAsyncClient() {
		return SqsAsyncClient.builder()
			.endpointOverride(URI.create(endpoint))
			.region(Region.EU_WEST_1)
			.credentialsProvider(DefaultCredentialsProvider.create())
			.build();
	}
}