Как заполнить группу в resequencer из интеграции весов

Question

Я использую resequencer для обеспечения правильного порядка сообщений. Когда какой-то процесс с несколькими сообщениями заканчивается, я хотел бы снова запустить тот же процесс с тем же идентификатором корреляции. Он не работает, потому что группа сообщений для определенного идентификатора корреляции не завершена и все еще существует для resequencer, поэтому нет сообщения для выпуска (все сообщения переигрываются с начала, поэтому нет сообщения с большим порядковым номером, а затем последний из первого процесса когда-либо получен). Для aggregator можно установить expire-groups-upon-completion, но, похоже, такой функции нет для resequencer. Возможно ли получить описанную функциональность?

Answer 1

Проблема заключается в том, что в отличие от агрегатора нет концепции «завершения» с точки зрения resequencer - она ​​не знает, что группа «завершена».

Именно по этой причине он недоступен в качестве опции на самом повторителе.

Вы можете предоставить внешний фасоль MessageGroupStore - resequencer создает собственный SimpleMessageStore по умолчанию, но вы можете предоставить ссылку на свой собственный компонент.

Затем, когда вы знаете, что группа «завершена», вы можете позвонить removeMessageGroup() с идентификатором корреляции, и это приведет к сбросу параметра resequencer.