我有一个带2个单独的SQS队列的春季启动项目。每个SQS队列都在单独的AWS帐户中，带有单独的IAM用户。我有两个独立的配置类，其中我将每个帐户/IAM用户/queue的凭据配置SQSASYNCCLIENT。

Question

the是一个可以传递给

factory

的参数。

因此，我在config类中定义了bean：

在a：

@SqsListener

在B：

Answer 1

@Bean
public SqsMessageListenerContainerFactory<Object> aSqsListenerContainerFactory() {
    return SqsMessageListenerContainerFactory
          .builder()
          .sqsAsyncClient( aSqsClient() ) //credentials are configured in aSqsClient
          .build();
}

然后在我的班级中，我可以说我可以说的消息

@Bean
public SqsMessageListenerContainerFactory<Object> bSqsListenerContainerFactory() {
    return SqsMessageListenerContainerFactory
          .builder()
          .sqsAsyncClient( bSqsClient() ) //credentials are configured in bSqsClient
          .build();
}

和

@SQSListener( factory = "aSqsListenerContainerFactory" )

现在我可以从两个队列/AWS帐户中接收消息。