java - spring 集成 inboundChannelAdapter 一次生成多条消息？

Question

我尝试定义一个 InboundChannelAdapter 来从队列 API(本例中为 Azure)读取消息。 native 方法如下所示:

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

这按预期工作 - 但我想知道是否有一种更有效的方法来定义适配器，该适配器能够从消息源一次读取多个 (maxMessagesPerPoll>1) 消息？是否有允许返回消息列表的 messageSource 接口(interface)？

Answer 1

您只需返回一 strip 有 List<QueueSource> 的消息即可有效负载并在下游添加一个分离器。