AMQP / RabbitMQ
Restorm implementuje AMQP 0-9-1, czyli protokół RabbitMQ.
Kliknięcie prawym przyciskiem w drzewie ▸ Dodaj ▸ Żądanie AMQP.
Konfiguracja wspólna
Section titled “Konfiguracja wspólna”| Pole | Rola |
|---|---|
| URL | amqp:// lub amqps:// |
| Vhost | Host wirtualny; domyślnie / |
| Użytkownik / Hasło | Hasło przyjmuje wartość typu Sekret |
| Tryb | publish, subscribe lub browse |
Tryb publish
Section titled “Tryb publish”| Pole | Rola |
|---|---|
| Exchange | Nazwa exchange’u; pusty ciąg znaków oznacza exchange domyślny |
| Routing key | Klucz routingu, który przyjmuje {{variables}} |
| Ładunek | Treść wiadomości |
Tryb subscribe
Section titled “Tryb subscribe”| Pole | Rola |
|---|---|
| Kolejka | Konsumowana kolejka |
| Automatyczne potwierdzanie | Włączone domyślnie; wyłączenie pozwala obserwować zachowanie przy ponownym dostarczaniu |
| Prefetch | Maksymalna liczba niepotwierdzonych wiadomości w locie |
Tryb browse
Section titled “Tryb browse”Pozwala przejrzeć zawartość kolejki bez jej konsumowania: Restorm pobiera z niej ograniczoną liczbę wiadomości (domyślnie 50) i odkłada je na miejsce.
To właśnie ten tryb odpowiada na pytanie „co znajduje się w tej kolejce?”, nie zakłócając pracy systemu. Jest dostępny w zakładce żądania; w odróżnieniu od dwóch pozostałych trybów nie ma dedykowanej akcji scenariusza.
W scenariuszu
Section titled “W scenariuszu”Połączenie AMQP (konsumuje kolejkę w trybie subscribe i emituje jedno
zdarzenie na każdą wiadomość), Publikacja AMQP (publikuje na exchange’u
i z kluczem routingu pobranymi z żądania) oraz Zamknięcie połączenia AMQP.
Zob. Połączenia i strumienie.
Fragmenty kodu
Section titled “Fragmenty kodu”Osiem celów: JavaScript (amqplib, w trybie publikacji, konsumpcji
i przeglądania), Python (pika), amqp-publish oraz amqp-consume
(amqp-tools), rabbitmqadmin.