агрегатор поведения при перезапуске сервера - весна интеграция

Question

Предпосылки -

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

• Текущий Behavior-> все сообщения, размещаемые в агрегаторе перейти к той же группе сообщений и не является новым, так как оно не отмечено полное, сообщения держать течет.
• Expected-> Если перезапуска сервера, агрегатор выбирает оставшиеся сообщения из хранилища сообщений, метки уже сохранялись те полный & затем обслуживать новые,

ли мои ожидания неправильно? Может ли кто-нибудь руководствоваться?

Answer 1

Я думаю, что мы сможем достичь ваших требований с помощью MessageGroupStoreReaper, который вы будете запускать только при запуске сервера, например. по ловле ContextRefreshedEvent:

MessageGroupStore поддерживает список этих обратных вызовов, которые он применяет, по требованию, ко всем сообщениям, чьи временные метки раньше, чем время в качестве параметра (см registerMessageGroupExpiryCallback (..) и expireMessageGroups (..) выше).

Метод expireMessageGroups можно вызывать со значением таймаута. Любое сообщение старше текущего времени минус это значение будет истекло, и будут применены обратные вызовы. Таким образом, пользователь магазина определяет, что означает группа сообщений «expiry».

http://docs.spring.io/spring-integration/reference/html/messaging-routing-chapter.html#reaper