Here's flow в a nutshell:"Repeat until condition satisfied" в Spring Integration
inputChannel->transformer->firstOutboundAdapter->pollingOutboundAdapter
Synopsis: inputChannel receives на incoming message, passes дальше к в transformer which в turn passes на transformed сообщение на firstOutboundAdapter. Последний вызывает веб-службу (проприетарный ...), чтобы запустить процесс, который требуется некоторое время для завершения. Чтобы узнать, какой статус этот процесс является другим веб-сервисом, необходимо периодически вызывать определение статуса.
Вопрос: Как я могу реализовать pollingOutboundAdapter для запроса веб-службы и периодически возвращать только когда правильный ответ был получен? Вот улов: я хотел бы поместить сообщение в очередь, обработать его и только вернуться в pollingOutboundAdapter, когда он будет готов. Я хотел бы избежать написания какого-либо повторения во время сценария и просто использовать обработку сообщений Spring Integration, если это возможно ...
Надеюсь, я достаточно подробно рассказал :) Любой конструктивный вклад очень ценится!