Потребительская идемпотентность, DLQ + повторение стюарда (срез 2)

Featurekamo-shared-library
Порезанный
26 июня 2026 г. в 01:48 UTC
Автор
Kamo
Обещать
419acb5

Добавляет ядро надежности, к которому подключается любой потребитель MLOS: ProcessedEvent dedup ledger (уникальное Consumer name+event id) + MlosDeadLetter DLQ + MlosDeadLetterStatus; IdempotentEventProcessor (INSERT-or-skip dedup в обработчике tx, поэтому отказ откатывает маркер; dead-letters past maxAttempts вместо петли; deadLetterUnprocessable для неразборчивого яда); DeadLetterReplayer (переоформляет письмо DEAD через почтовый ящик в качестве нового события с причинно-следственной линией -> без столкновения msg id-unique/dedup-window, метки REPLAYED). MlosEventEnvelope получил @Jacksonized за десериализацию в оба конца. Новые @Components используют опцию mlos.outbox.enabled; РЕПО находятся в уже отсканированном пакете. Live AbstractMlosDurableConsumer (подписка НАТС) откладывается до своего первого конкретного потребителя.

Все изменения

Как вы видите судоходство?

Каждое из этих обновлений автоматически попадает в ваше рабочее пространство. Начните бесплатно и смотрите, как он растет неделю за неделей.

Начните бесплатно навсегдаПосмотреть цены