用例轮询 HttpService 并执行进一步的操作

Question

我的用例是这样的。我想定期轮询休息服务使用该信息调用另一个休息服务。我的 DSL 如下所示

  public IntegrationFlow flow() {
    return IntegrationFlows
        .from(() -> "messageSource", c -> c.poller(Pollers.fixedRate(5000).maxMessagesPerPoll(1)))
        .handle(Http.outboundChannelAdapter("firstRestServiceUrl"))
        .handle(Http.outboundChannelAdapter("secondRestServiceUrl")).get();
  }

我的问题是第一个处理方法会在回复通道上回复并且消息不会进一步传送到第二个处理程序。

还是我的理解有误？应该使用一个转换器来调用 firstRestServiceUrl 而不是 handle 方法？

我从文档中的理解是句柄相当于一个服务激活器，我应该可以将输出通道设置为我的第二个服务激活器的输入！！

Answer 1

通道适配器是单向集成，因此流程在第一个适配器处停止。

您需要一个出站网关。

用例轮询 HttpService 并执行进一步的操作

Use-case polling HttpService and performing further actions

spring-integration

spring-integration-dsl