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

Question

我试图定义一个 InboundChannelAdapter 来从队列 API（在本例中为天蓝色）读取消息。本机方法如下所示：

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

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

标签： javaspringspring-integration

Answer 1

您可以简单地返回带有List<QueueSource>有效负载的消息并在下游添加拆分器。