- Expediere
- 4 septembrie 2026 la 20:02 UTC
- Autor
- Kamo
- Comite
- 6c253b6
Un consumator de împingere durabilă admite exact un abonat. A doua capsulă care leagă acelaşi nume este refuzat cu [SUB-90012] Consumatorul este deja obligat la un abonament, și nimic nu retries. ChatSessionAbonamentManager nume sale durabile după sesiunea de chat GUID, astfel încât cu două Capsulele MediaService oricare ar fi legat o conversație mai întâi ar deține în tăcere și fiecare membru Al cui WebSocket a aterizat pe cealaltă capsulă nu va primi nimic. Fără mesaje, fără chitanţe citite. evenimente cu membri adăugați, nici o eroare. Această proprietate unică este motivul pentru care MediaService a fost fixat la unul Replica, și de ce o implementare a acesteia este o pană totală de chat mai degrabă decât o răsturnare. subscrieEfemeral() creează în schimb un consumator anonim. Nu există nici o identitate inter-pod pentru a ciocni peste, astfel încât fiecare pod primește fiecare mesaj și fani propriilor clienți STOMP În-Hap broker simplu necesită. Păstrează filtrulSubiect calea durabilă învățată pentru a seta (un filtru gol consumă întregul flux), și adaugă un inactivThreshold astfel încât un pod care este SIGKILLed fără a se dezabona nu lasă consumatorul său pe râu pentru totdeauna. Nici o schimbare de comportament pentru apelanții existenți: subscrie () este neatins, și bucla de livrare ambele utilizarea căi este acum o metodă astfel încât acestea nu pot deriva. Consumatorii efemeri nu redau mesajele publicate în timp ce nimic nu a fost subscris. Nici pe cele durabile, ambele folosesc DeliverPolicy. Nou .