- Navios
- 15 de maio de 2026 às 20:48 UTC
- Autor
- Kamo
- Enviar
- e8ff33f
Três mudanças agrupadas porque todos eles vivem em WebhookDeliveryWorker e fazer sentido juntos: 1. Mudar de núcleo NATS expedidor para um cliente de impulso durável JetStream ("los-pipeline-webhook-worker", AckPolicy. Explícito). Reinicia a repetição a contagem de tentativas vem de msg.metaData().liveredCount() assim, o WebhookDelivery auditoria log reflete redelivery em vez de um ciclo em processo. MaxDeliver caps redelivery. 2. Dispatch cada mensagem para um pequeno ScheduedExecutorService assim um lento (10s-timeout) assinante não pode fazer backup da linha de despacho NATS. 3. Assinar 't.body' (estilo Stripe/GitHub) e emitir cabeçalhos X-Kamo-Timestamp + X-Kamo-Assinatura: t=<ts>,v1=<hex> assim que uma escuta O pedido não pode ser reproduzido indefinidamente. deliverForOrg não é mais @Transactional: uma tentativa HTTP falhada re-throws Então a JetStream redelivers, e queremos que a linha de auditoria persista em sua própria transacção curta em vez de voltar com o âmbito exterior.