Dayanıklı JetStream tüketici, executor izolasyon, zamansız imzalar

Featurekamo-shared-library
Shiked
15 Mayıs 2026 20:48 UTC
Yazar
Kamo
Commit
e8ff33f

Üç değişiklik paketlendi çünkü hepsi WebhookDeliveryWorker ve Birlikte mantıklı olun: 1. Çekirdek NATS senter'den JetStream'a geçiş ("los-borline-webhook-worker", AckPolicy. Explicit). Restarts replay Şaşırtıcı olmayan olaylar; sayı msg.metaData().deliveredCount()'den geliyor. Bu yüzden WebhookDelivery denetim kaydı kırmızıelivery'yi bir andan ziyade yansıtır Süreç döngüsü. maxDeliver caps redelivery. 2. Her mesajı küçük bir ScheduledExecutorService'a devre dışı bırakmak, böylece yavaş yavaş bir şekilde (10s-timeout) abone, NATS gönderimi geri alamaz. 3. İşaret 't.body' (Stripe/GitHub tarzı) ve başlıkları yay. X-Kamo-Timestamp + X-Kamo-Signature: t=<ts>,v1=<hex> bu yüzden bir eavesdroked İstek süresiz olarak yeniden oynatılamaz. TeklifForOrg artık @Transactional değildir: başarısız bir HTTP denemesi yeniden başlıyor Bu yüzden JetStream redelivers ve denetim sırasını kendi başına sürdürmek istiyoruz Dış kapsamı ile geri dönmek yerine kısa işlem.

Tüm değişiklikler

Kargoyu gördüğünüz gibi?

İş alanınızda bu güncellemelerden her biri otomatik olarak. Ücretsiz başlayın ve haftadan sonra büyümesini izleyin.

Sonsuza Kadar Ücretsiz BaşlangıçFırsatları Görüntüle