Потребитель Durable JetStream, изоляция исполнителя, метки времени

Featurekamo-shared-library
Порезанный
15 мая 2026 г. в 20:48 UTC
Автор
Kamo
Обещать
e8ff33f

Три изменения в комплекте, потому что все они живут в WebhookDeliveryWorker. иметь смысл вместе: 1.Переключение с основного диспетчера NATS на надежного потребителя JetStream ("los-pipeline-webhook-worker", AckPolicy). Ясно. Восстановление воспроизведения безотказные события; подсчет попыток происходит от msg.metaData().deliveredCount() Таким образом, журнал аудита WebhookDelivery отражает перепродажу, а не В процессе. maxDeliver перезагрузка. 2. Отправляйте каждое сообщение в небольшую Службу Запланированных Исполнителей так медленно (10-тайм-аут) абонент не может создать резервную копию потока диспетчера NATS. 3. Подпишите 't.body' (стиль Стрип/GitHub) и излучайте заголовки X-Kamo-Timestamp + X-Kamo-Signature: t=<ts>,v1=<hex> Запрос не может быть воспроизведен бесконечно. DeliverForOrg больше не @Transactional: неудачная попытка HTTP-бросков Итак, JetStream перезагружает, и мы хотим, чтобы аудиторский ряд сохранился в своем собственном. Короткая транзакция, а не откат с внешней областью.

Все изменения

Как вы видите судоходство?

Каждое из этих обновлений автоматически попадает в ваше рабочее пространство. Начните бесплатно и смотрите, как он растет неделю за неделей.

Начните бесплатно навсегдаПосмотреть цены