x-overflow în Cozile RabbitMQ în RabbitMQ

Comportamentul la depășirea x-max-length: elimină mesajele vechi (drop-head) sau respinge noile scrieri (reject-publish).

Sintaxă
arguments={'x-overflow': 'reject-publish'} # sau 'drop-head'

Cele două strategii de depășire (Overflow)

  • drop-head (implicit): Mesajele cele mai vechi din fața cozii sunt șterse sau trimise în DLX pentru a face loc noilor mesaje sosite. Ideal pentru telemetrie unde interesează doar cele mai recente date.
  • reject-publish: Brokerul respinge publicarea noilor mesaje și trimite NACK producătorului (dacă Publisher Confirms este activ). Ideal în sisteme financiare unde datele istorice nu pot fi aruncate sub nicio formă.
Exemplu Concret: Respingerea noilor scrieri la depășire
channel.queue_declare(
    queue='plati_strict',
    arguments={
        'x-max-length': 5000,
        'x-overflow': 'reject-publish'
    }
)
Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: x-overflow în Cozile RabbitMQ

Ai o nelămurire despre utilizarea comenzii x-overflow în Cozile RabbitMQ sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.