- Expediere
- 15 mai 2026 la 20:48 UTC
- Autor
- Kamo
- Comite
- e8ff33f
Trei schimbări grupate pentru că toate trăiesc în WebhookDeliveryWorker și face sens împreună: 1. Treceți de la dispecer NATS de bază la un consumator de împingere JetStream durabil ("Los-pipeline-webhook-worker," AckPolicy. Explicit). Reporneşte reluarea evenimente neachitate; numărul de încercări vine de la msg.metaData().livratCount() astfel încât jurnalul de audit WebhookDelivery reflectă relivrare mai degrabă decât un bucla în proces. maxDeliver caps relivrare. 2. Trimite fiecare mesaj la un mic programatExecutorService astfel încât un lent (10s-timeout) abonatul nu poate susţine firul dispecerului NATS. 3. Semnați 't.body' (stilul Stripe/GitHub) și emiteți antete X-Kamo-Timestamp + X-Kamo-Signature: t=<ts>,v1=<hex> so an takesloaded cererea nu poate fi reluată pe termen nelimitat. LivrareForOrg nu mai este @Transacţional: o încercare HTTP eşuată de re-aruncare Deci JetStream redelivers, și vrem ca rândul de audit să persiste în propria sa tranzacție scurtă, mai degrabă decât rularea înapoi cu domeniul de aplicare exterior.