java - Spring集成中的"Repeat until condition satisfied"

Question

简而言之，流程如下:

inputChannel->transformer->firstOutboundAdapter->pollingOutboundAdapter

概要:inputChannel 接收传入消息，传递到转换器，转换器又将转换后的消息传递到firstOutboundAdapter。后者调用 Web 服务(专有...)来启动一个需要一段时间才能完成的过程。为了查明进程的状态，需要定期调用另一个 Web 服务来确定状态。

问题:如何实现 pollingOutboundAdapter 来定期查询 Web 服务并仅在收到正确响应时才返回？问题是:我想在队列中弹出一条消息，对其进行处理，然后仅在准备就绪时返回到 pollingOutboundAdapter。我想避免编写某种重复的 while 场景，如果可能的话，只使用 Spring Integration 消息处理...

我希望我的沟通足够清晰:)非常感谢任何建设性的意见!

Answer 1

尝试使用RequestHandlerRetryAdvice找出解决方案:http://docs.spring.io/spring-integration/docs/4.3.6.RELEASE/reference/html/messaging-endpoints-chapter.html#message-handler-advice-chain

您可以抛出异常，直到满足某种条件，retryTemplate 将执行相同的调用，直到成功。