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

Question

我的用例是这样的。我想定期轮询休息服务，并且 使用该信息调用另一个 REST 服务。我的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();
}

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

还是我的理解是错误的？应该使用一个转换器，它反过来调用第一个RestServiceUrl而不是句柄方法？

我从文档中的理解是，句柄等效于服务激活器，我应该能够将输出通道设置为我的第二个服务激活器的输入！！

Answer 1

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

您需要一个出站网关。