Агрегирование нескольких групп в определенных условиях, которые могут быть верны в одной из них

Question

У меня есть строка, которая вызывает два веб-сервиса для этого

и увеличить глобальный счетчик для ответов на перехватчике для каждого агрегатора

request -> success -> completedAggreator ( release strategy if  doneCondition())

request -> fail-> FailAggregator ( release strategy if doneCondition())

doneCondition(){
    numberOfResponse = line * 2
}

проблема в том, что последний ответ может поступить на один из агрегаторов и успешно выпущен, но другой агрегатор все еще ожидает, так как он не получил последний ответ для проверки при условии освобождения

Answer 1

Это звучит как задача для Scatter-Gather: https://docs.spring.io/spring-integration/docs/5.0.5.RELEASE/reference/html/messaging-routing-chapter.html#scatter-gather.

В противном случае неясно, зачем вам два агрегатора, а группа основана на корреляции независимо от результата выполнения.

Пожалуйста, объясните свою бизнес-задачу. Сейчас не совсем понятно, что ты пытаешься сделать.