Idempotência do consumidor, DLQ + replay de mordomo (Slice 2)

Featurekamo-shared-library
Navios
26 de junho de 2026 às 01:48 UTC
Autor
Kamo
Enviar
419acb5

Adiciona o núcleo de confiabilidade em que qualquer consumidor da MLOS se conecta: ProcessedEvent dedup bookger (unique consumer name+event id) + MlosDeadLetter DLQ + MlosDeadLetterStatus; IdempotentEventProcessor (INSERT-or-skip dedup in the handler's tx so a failure rolls back the mark; Dead-letters past maxAttemptts em vez de looping; deadLetterUnprocessable for unparseable envenen); DeadLetterReplayer (re-enqueue uma letra DEAD através da caixa de saída como um evento NOVOId with causationId lingene -> no msg id-unique/dedupwindow colision, marca REPLAYED). MlosEventEnvelope ganha @Jacksonized para desserialização de ida e volta. Novos @Components compartilham o mlos.outbox. habilitado opt-in; repos estão no pacote já escaneado. Live AbstractMlosDurávelConsumidor (subscrição NATS) diferiu para o seu primeiro consumidor concreto.

Todas as alterações

Como o que vês no transporte?

Cada uma dessas atualizações pousa automaticamente em seu espaço de trabalho. Comece grátis e veja crescer semana após semana.

Começar Livre Para SempreVer Preços