Crean proactivamente consumidor NATS en creación de sesión para evitar pérdidas de mensajes

FixMediaService
Se descapó
25 de abril de 2026 a las 17:56 UTC
Autor
Kamo
Compromit
436811a

Anteriormente el consumidor de presión NATS JetStream sólo se creó cuando un cliente STOMP enviado /app/chat/suscribirse. Con DeliverPolicy.Nuevo, cualquier mensaje publicado antes de un los consumidores existen que se pierden permanentemente. nunca aparecer en kamo-internal a menos que el agente se sume primero. - Extraer la lógica de suscripción NATS en ChatSessionSubscriptionManager (idempotent asegurarse Suscripción, arregla id serializado como cuerda para evitar la pérdida de precisión de JS en Identificacións de CockroachDB unique.rowid) - ChatWebSocketLos delegados de Contralores suscribirse a la misiónsion (). - PublicChatService llama a asegurar la suscripción() inmediatamente después de la creación de la MediaSession (por lo que el consumidor existe antes de que llegue el primer mensaje de visitante) y de nuevo en sendSupportMessage() como un retroceso

Todos los cambios

Como lo que ves enviaste?

Cada una de estas actualizaciones aterriza en su espacio de trabajo automáticamente. Empieza gratis y verlo crecer semana tras semana.

Arranzar gratis para siempreVer Precios