- Verschifft
- 15. Mai 2026 um 20:48 UTC
- Autor
- Kamo
- Ausschuss
- e8ff33f
Drei Änderungen gebündelt, weil sie alle leben in WebhookDeliveryWorker und machen gemeinsam Sinn: 1. Wechseln Sie vom Kern NATS Disponent zu einem JetStream langlebigen Push-Konsumenten ("los-pipeline-webhook-worker", AckPolicy.Explicit). Restartet Replay ungeackte Ereignisse; Versuchszahl stammt aus msg.metaData().deliveredCount() so die WebhookDelivery Audit Log spiegelt Redelivery in-Prozess-Schleife. maxDiver Kappen redelivery. 2. Verschicken Sie jede Nachricht an einen kleinen ScheduledExecutorService so eine langsame (10s-timeout) Teilnehmer können den NATS-Diser-Thread nicht unterstützen. 3. Unterschreiben 't.body' (Stripe/GitHub style) und strahlen Header aus X-Kamo-Zeitstempel + X-Kamo-Signature: t=<ts>v1=<hex? also ein Lauschangriff Anfrage kann nicht auf unbestimmte Zeit wiederholt werden. deliverForOrg ist nicht mehr @Transaktional: ein gescheiterter HTTP-Versuch wirft also JetStream redelivers, und wir wollen, dass die Prüfungsreihe in seiner eigenen fortbestehen kurze Transaktion, anstatt mit dem äußeren Umfang zurück zu rollen.