Весной интеграции inboundChannelAdapter производят более одного сообщения одновременно? - PullRequest
Новая
       27

Весной интеграции inboundChannelAdapter производят более одного сообщения одновременно?

0 голосов
/ 10 июля 2019

Я попытался определить InboundChannelAdapter для чтения сообщений из API очереди (в данном случае Azure). Нативный подход выглядит следующим образом: 

  @Bean
  @InboundChannelAdapter(value = "myChannelExample",
                         poller = @Poller(fixedDelay = "1000",
                                          maxMessagesPerPoll = "1"))
  public MessageSource<QueueMessage> queueReadingMessageSource() {
      return wrapMessage(queueClient.readMessage())
  }

Это работает, как и ожидалось - но мне было интересно, есть ли более эффективный способ определения адаптера, который мог бы читать несколько (maxMessagesPerPoll> 1) сообщений одновременно из источника сообщений? Есть ли интерфейс messageSource, который позволяет возвращать список сообщений?

1 Ответ

1 голос
/ 10 июля 2019

Вы можете просто вернуть сообщение с полезной нагрузкой List<QueueSource> и добавить сплиттер вниз по течению.

...