În mod nativ, un exchange încearcă să livreze mesajele instantaneu către cozi. Pentru scenarii precum „Trimite un email de coș abandonat după 30 de minute” sau „Anulează rezervarea neplătită după 15 minute”, plugin-ul rabbitmq_delayed_message_exchange reține mesajul în interiorul exchange-ului pentru numărul specificat de milisecunde.
Publicarea unui mesaj amânat cu header-ul x-delay
import pika
channel.exchange_declare(
exchange='exchange-intarziat',
type='x-delayed-message',
arguments={'x-delayed-type': 'direct'}
)
# Planificăm livrarea mesajului peste 30.000 milisecunde (30 de secunde):
proprietati = pika.BasicProperties(
headers={'x-delay': 30000},
delivery_mode=2
)
channel.basic_publish(
exchange='exchange-intarziat',
routing_key='notificari.email',
body=b'Verifica produsele lasate in cos!',
properties=proprietati
)
Întrebări & Exemple de Cod:
Mesaje Întârziate și Planificate în RabbitMQ: Plugin-ul Delayed Message ExchangeAi o nelămurire despre utilizarea comenzii
Mesaje Întârziate și Planificate în RabbitMQ: Plugin-ul Delayed Message Exchangesau 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.