Spring Cloud AWS несколько слушателей sqs - PullRequest
Новая
       8

Spring Cloud AWS несколько слушателей sqs

2 голосов
/ 14 марта 2019

В моем проекте есть слушатель 2 sqs.Я хочу, чтобы у одного из них были одинаковые настройки, а у одного - другие.Единственное значение, которое я хочу изменить, это maxNumberOfMessages.

Какой самый практичный способ сделать это?я хочу установить другое значение maxNumberOfMessages для одного из слушателей.

это моя конфигурация; 

@Bean
public AWSCredentialsProvider awsCredentialsProvider(@Value("${cloud.aws.profile}") String profile,
                                                     @Value("${cloud.aws.region.static}") String region,
                                                     @Value("${cloud.aws.roleArn}") String role,
                                                     @Value("${cloud.aws.user}") String user) {
    ...

    return new AWSStaticCredentialsProvider(sessionCredentials);
}

@Bean
@Primary
@Qualifier("amazonSQSAsync")
public AmazonSQSAsync amazonSQSAsync(@Value("${cloud.aws.region.static}") String region, AWSCredentialsProvider awsCredentialsProvider) {
    return AmazonSQSAsyncClientBuilder.standard()
            .withCredentials(awsCredentialsProvider)
            .withRegion(region)
            .build();
}

@Bean
@Primary
public SimpleMessageListenerContainerFactory simpleMessageListenerContainerFactory(AmazonSQSAsync amazonSqs) {
    SimpleMessageListenerContainerFactory factory = new SimpleMessageListenerContainerFactory();
    factory.setAmazonSqs(amazonSqs);
    factory.setMaxNumberOfMessages(1);
    factory.setWaitTimeOut(10);
    factory.setQueueMessageHandler(new SqsQueueMessageHandler());
    return factory;
}

это слушатель; 

@SqsListener(value = "${messaging.queue.blabla.source}", deletionPolicy = SqsMessageDeletionPolicy.NEVER)
public void listen(Message message, Acknowledgment acknowledgment, @Header("MessageId") String messageId) {
    log.info("Message Received");

    try {
        ....
        acknowledgment.acknowledge().get();
    } catch (InterruptedException e) {
        e.printStackTrace();
    } catch (ExecutionException e) {
        e.printStackTrace();
    } catch (Exception ex) {
        throw new RuntimeException(ex.getMessage());
    }
}

1 Ответ

0 голосов
/ 14 марта 2019

Я нашел решение и поделился примером репо на github. github link

если я добавлю аннотацию @EnableAsync к классу слушателя и аннотацию @Async к методу обработчика, моя проблема решается:)

...