AMQP / RabbitMQ
Restorm implementează AMQP 0-9-1, protocolul RabbitMQ.
Clic dreapta în arbore ▸ Adaugă ▸ Cerere AMQP.
Configurare comună
Section titled “Configurare comună”| Câmp | Rol |
|---|---|
| URL | amqp:// sau amqps:// |
| Vhost | Gazda virtuală; / implicit |
| Utilizator / Parolă | Parola acceptă o valoare de tip Secret |
| Mod | publish, subscribe sau browse |
Modul publish
Section titled “Modul publish”| Câmp | Rol |
|---|---|
| Exchange | Numele exchange-ului; un șir gol desemnează exchange-ul implicit |
| Cheie de rutare | Cheia de rutare, care acceptă {{variables}} |
| Sarcină utilă | Corpul mesajului |
Modul subscribe
Section titled “Modul subscribe”| Câmp | Rol |
|---|---|
| Coadă | Coada consumată |
| Confirmare automată | Activată implicit; dezactivați-o pentru a observa comportamentul de relivrare |
| Prefetch | Numărul maxim de mesaje neconfirmate în zbor |
Modul browse
Section titled “Modul browse”Consultă conținutul unei cozi fără să îl consume: Restorm extrage din ea un număr limitat de mesaje (50 implicit) și le pune la loc.
Este modul pe care îl dorim pentru a răspunde la întrebarea „ce se află în coada asta de așteptare?” fără să perturbăm sistemul. Este disponibil în fila de cerere; spre deosebire de celelalte două moduri, nu are o acțiune de scenariu dedicată.
Într-un scenariu
Section titled “Într-un scenariu”Conexiune AMQP (consumă coada în modul subscribe și emite un eveniment
pentru fiecare mesaj), Publicare AMQP (publică pe exchange-ul și pe cheia de
rutare ale cererii) și Închidere conexiune AMQP. Vedeți
Conexiuni și fluxuri.
Fragmente de cod
Section titled “Fragmente de cod”Opt ținte: JavaScript (amqplib, în publicare, consumare și inspecție), Python
(pika), amqp-publish și amqp-consume (amqp-tools), rabbitmqadmin.