Skip to content

Commit 1b82edb

Browse files
authored
Auto-configure an async SNS client (#574)
1 parent 1579a13 commit 1b82edb

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

spring-cloud-aws-autoconfigure/src/main/java/io/awspring/cloud/autoconfigure/messaging/SnsAutoConfiguration.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
import com.amazonaws.auth.AWSCredentialsProvider;
2424
import com.amazonaws.regions.Regions;
2525
import com.amazonaws.services.sns.AmazonSNS;
26-
import com.amazonaws.services.sns.AmazonSNSClient;
26+
import com.amazonaws.services.sns.AmazonSNSAsyncClient;
2727
import com.amazonaws.services.sns.message.SnsMessageManager;
2828
import io.awspring.cloud.context.annotation.ConditionalOnMissingAmazonClient;
2929
import io.awspring.cloud.core.config.AmazonWebserviceClientFactoryBean;
@@ -83,9 +83,9 @@ public class SnsAutoConfiguration {
8383

8484
@ConditionalOnMissingAmazonClient(AmazonSNS.class)
8585
@Bean
86-
public AmazonWebserviceClientFactoryBean<AmazonSNSClient> amazonSNS(SnsProperties properties) {
87-
AmazonWebserviceClientFactoryBean<AmazonSNSClient> clientFactoryBean = new AmazonWebserviceClientFactoryBean<>(
88-
AmazonSNSClient.class, this.awsCredentialsProvider, this.regionProvider, this.clientConfiguration);
86+
public AmazonWebserviceClientFactoryBean<AmazonSNSAsyncClient> amazonSNS(SnsProperties properties) {
87+
AmazonWebserviceClientFactoryBean<AmazonSNSAsyncClient> clientFactoryBean = new AmazonWebserviceClientFactoryBean<>(
88+
AmazonSNSAsyncClient.class, this.awsCredentialsProvider, this.regionProvider, this.clientConfiguration);
8989
Optional.ofNullable(properties.getEndpoint()).ifPresent(clientFactoryBean::setCustomEndpoint);
9090
return clientFactoryBean;
9191
}

0 commit comments

Comments
 (0)