Перезапись сообщений с одинаковым идентификатором корреляции и порядковым номером весной

Question

Основываясь на моих собственных экспериментах (не можете найти это в любом месте), если 2 сообщения, имеющие одинаковый идентификатор корреляции и порядковый номер, агрегатор будет принимать только первое сообщение и отбросить/проигнорировать другое сообщение.

Есть ли способ заставить агрегатор использовать последнее сообщение, полученное вместо этого?

Агрегация объединит полезную нагрузку в 1 строку.

Простой сценарий: 3 сообщения с такими же ID корреляции и размером последовательности 2, упорядоченное по времени получил

• последовательности #: 1; полезная нагрузка: abc
• последовательность #: 1; полезная нагрузка: def
• последовательность #: 2; Полезная нагрузка: ГХИ

Токовый выход: abcghi

Ожидаемый выход: defghi

Этот сценарий происходит, когда последовательность # 2 отсутствует, который предназначен для 1-го сообщения. И идентификатор корреляции (полученный из декодированной полезной нагрузки) очень ограничен, поэтому он будет использоваться несколько раз.

Первоначальное сообщение

Необработанные сообщения пришли в следующем формате:

• "Последовательность Размер", "порядковый номер", "ID", "Текст"
• ID колеблется между 0 -9
• пример сообщение: 2,1,8, а

образец сырого Сообщ е полезной нагрузка:

• 2,1,8, а
• 2,1,8, Защита
• 2,2,8, ГХИ

Агрегатор в основном объединить текст

Answer 1

Вам нужно использовать специальную стратегию выпуска (она может иметь ту же логику, что и по умолчанию SequenceSizeReleaseStrategy, но это не может быть этот класс). При стандартной стратегии повторяющиеся последовательности пропускаются.

Однако для обеспечения желаемого поведения вам также понадобится специальный журнал групп сообщений. иначе выход будет abcdefghi.

Однако отброшенное сообщение не будет отправлено на канал сброса в этом случае.

Как правило, не рекомендуется повторно использовать идентификатор корреляции; если необходимо, используйте group-timeout или жнец для отбрасывания частичной группы до любой возможности повторного использования идентификатора корреляции.

Кстати, вам может быть проще использовать пользовательские CorrelationStrategy и ReleaseStrategy вместо использования по умолчанию и манипулирования заголовками.