Я бы хотел достичь чего -то подобного: < /p>
[Source] --> [Splitter] --B--> [Processor] --B--> [Aggregator] ---> [Sink]
| ^
| |
|--------------------C-------------------|
< /code>
После нескольких процессоров, которые включают в себя бизнес -логику,
Специальный производитель должен излучать несколько сообщений типа B вместе с управляющим сообщением c. < /p>
Процессоры с дальнейшей бизнес -логикой будут работать на этих сообщениях. генерирует сообщения (b), поэтому агрегатор может иметь знание, были ли < /p>
Все ожидаемые сообщения B прибыли < /li>
Тайм -аут произошел < /li>
< /ol>
Я знаю, что агрегатор может быть в целом. это?>
Подробнее здесь: https://stackoverflow.com/questions/364 ... -spring-xd
